使用的IDE:Intellj idea 13.1
数据库中表的增删改查
<span style="white-space:pre"> </span>static Connection conn; <span style="white-space:pre"> </span>//static PreparedStatement st; <span style="white-space:pre"> </span>static java.sql.Statement stat; String url = "jdbc:sqlserver://EE-LAB; DatabaseName=Fantastic FourMen"; String name = "user"; String passWord = "123456"; //Connection con=null; //java.sql.Statement stat=null; //ResultSet rs=null; try { //Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); Class.forName("com.microsoft.sqlserver.jdbc.sqlServerDriver"); System.out.println("驱动程序加载"); System.out.println("即将连接到数据库"); } catch (ClassNotFoundException e) { System.out.println("无法加载驱动程序" + e.getMessage()); e.printstacktrace(); return; } conn = DriverManager.getConnection(url,name,passWord); conn.close();
public static void insertData(String insertsql) { try { //String sql = Format("SET NOCOUNT ON "+ insertsql); stat = conn.createStatement(); //ResultSet rs = stat.executeQuery(insertsql); int count = stat.executeUpdate(insertsql); //用这个代替ResultSet rs = stat.executeQuery(insertsql); 同样可以插入 System.out.println("成功插入" + count + "行"); //rs.close(); stat.close(); } catch (sqlException e) { System.out.println("数据插入失败"); e.printstacktrace(); } }
3、删除数据
private static void deleteData() { String deletesql = "DELETE FROM new_table " + "WHERE ID = 5 "; try { stat = conn.createStatement(); int count = stat.executeUpdate(deletesql); stat.close(); System.out.println("删除了" + count + "条数据"); } catch (sqlException e) { System.out.println("数据删除失败"); e.printstacktrace(); } }
private static void upData() { String updatesql = "UPDATE testTable SET age = 5 WHERE name ='ling'"; try { stat = conn.createStatement(); int count = stat.executeUpdate(updatesql); stat.close(); } catch (sqlException e) { System.out.println("数据修改失败"); e.printstacktrace(); } }
5、查询数据
public static void serchData(String serchsql) { try { stat = conn.createStatement(); ResultSet rs = stat.executeQuery(serchsql); System.out.println("查询结果:"); while (rs.next()) { System.out.println(rs.getString(1) + " " + rs.getString(2) + " " + rs.getString(3) + " " + rs.getString(4)); } rs.close(); stat.close(); } catch (sqlException e) { System.out.println("查询失败"); e.printstacktrace(); } }
private static void createInsertNewTable() { String serchsql = "select * from new_table";//创建新表 String insertsql = "insert into new_table" + " select name,age,sex " + "from testTable";//将testTable表中的数据插入到新表中 createTable("new_table"); //创建一张新表 insertData(insertsql); //插入数据 serchData(serchsql); //查找数据 }
private static void createTable(String tableName) { String createTablesql = "create table " + tableName + " (ID int primary key,name ntext,age int,sex nchar(10))"; //System.out.println(createTablesql); try { stat = conn.createStatement(); int count = stat.executeUpdate(createTablesql); stat.close(); //ResultSet rs = stat.executeQuery(createTablesql); //rs.close(); } catch (sqlException e) { System.out.println(tableName + "创建失败"); e.printstacktrace(); } }