JDBC:
创建SQL语句对象 Statement statement = (Statement) con.createStatement() ;
调用执行 statement.executeUpdate(sqlString);
释放资源 statement.close();
一 : 创建表的操作代码:
1 package JDBC; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.SQLException; 6 7 import com.mysql.jdbc.Statement; 8 9 public class Demo { 10 // 数据库地址 11 private static String dbUrl="jdbc:mysql://localhost:3306/JavaJDBC"; 12 // 用户名 13 private static String dbUserName="root"; 14 // 密码 15 private static String dbPassword="root"; 16 // 驱动名称 17 private static String jdbcName="com.mysql.jdbc.Driver"; 18 19 public static void main(String[] args) { 20 try { 21 Class.forName(jdbcName); 22 System.out.println("加载驱动成功！"); 23 } catch (ClassNotFoundException e) { 24 // TODO Auto-generated catch block 25 e.printStackTrace(); 26 System.out.println("加载驱动失败！"); 27 } 28 Connection con=null; 29 try { 30 // 获取数据库连接 31 con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword); 32 System.out.println("获取数据库连接成功！"); 33 System.out.println("进行数据库操作！"); 34 // 创建sql语句 35 String sqlString = "CREATE TABLE t_student(id BIGINT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(20),age INT)"; 36 // 创建语句对象 37 Statement statement = (Statement) con.createStatement() ; 38 // 执行sql语句 39 statement.executeUpdate(sqlString); 40 statement.close(); 41 } catch (SQLException e) { 42 // TODO Auto-generated catch block 43 e.printStackTrace(); 44 }finally{ 45 try { 46 con.close(); 47 } catch (SQLException e) { 48 // TODO Auto-generated catch block 49 e.printStackTrace(); 50 } 51 } 52 } 53 54 }
二 : 处理异常和关闭资源(对上部分代码优化)
1 package JDBC; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.SQLException; 6 7 import com.mysql.jdbc.Statement; 8 9 public class Demo { 10 // 数据库地址 11 private static String dbUrl="jdbc:mysql://localhost:3306/JavaJDBC"; 12 // 用户名 13 private static String dbUserName="root"; 14 // 密码 15 private static String dbPassword="root"; 16 17 public static void main(String[] args) { 18 Connection con=null; 19 Statement statement = null ; 20 try { 21 // 获取数据库连接 22 con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword); 23 System.out.println("获取数据库连接成功！"); 24 System.out.println("进行数据库操作！"); 25 // 创建sql语句 26 String sqlString = "CREATE TABLE t_student(id BIGINT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(20),age INT)"; 27 // 创建语句对象 28 statement = (Statement) con.createStatement() ; 29 // 执行sql语句 30 statement.executeUpdate(sqlString); 31 } catch (SQLException e) { 32 // TODO Auto-generated catch block 33 e.printStackTrace(); 34 }finally{ 35 try { 36 con.close(); 37 statement.close(); 38 } catch (SQLException e) { 39 // TODO Auto-generated catch block 40 e.printStackTrace(); 41 } 42 } 43 } 44 45 }
三 : DML操作
操作与上述常见表相同,只需修改SQL语句
四 : 查询操作
1 package JDBC; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.SQLException; 6 7 import com.mysql.jdbc.ResultSet; 8 import com.mysql.jdbc.Statement; 9 10 public class Demo { 11 // 数据库地址 12 private static String dbUrl="jdbc:mysql://localhost:3306/JavaJDBC"; 13 // 用户名 14 private static String dbUserName="root"; 15 // 密码 16 private static String dbPassword="root"; 17 18 public static void main(String[] args) throws ClassNotFoundException { 19 Class.forName("com.mysql.jdbc.Driver") ; 20 Connection con=null; 21 Statement statement = null ; 22 try { 23 // 获取数据库连接 24 con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword); 25 System.out.println("获取数据库连接成功！"); 26 System.out.println("进行数据库操作！"); 27 // 创建sql语句 28 String sqlString = "select * from t_student"; 29 // 创建语句对象 30 statement = (Statement) con.createStatement() ; 31 // 执行sql语句 32 ResultSet resultSet = (ResultSet) statement.executeQuery(sqlString); 33 // 取出查询结果 34 while(resultSet.next()){ 35 long id = resultSet.getLong("id") ; 36 String nameString = resultSet.getString("name") ; 37 long age = resultSet.getLong("age") ; 38 System.out.println(id + " " + nameString + " " + age); 39 } 40 } catch (SQLException e) { 41 // TODO Auto-generated catch block 42 e.printStackTrace(); 43 }finally{ 44 try { 45 con.close(); 46 statement.close(); 47 } catch (SQLException e) { 48 // TODO Auto-generated catch block 49 e.printStackTrace(); 50 } 51 } 52 } 53 54 }
核心代码:
// 执行sql语句
ResultSet resultSet = (ResultSet) statement.executeQuery(sqlString);
// 取出查询结果
while(resultSet.next()){
long id = resultSet.getLong("id") ;
String nameString = resultSet.getString("name") ;
long age = resultSet.getLong("age") ;
System.out.println(id + " " + nameString + " " + age);
}
解释: executeQuery返回一个ResultSet,是对应的表,开始指向第一行,也就是每一列的名称,此处为id,name,age,然后通过next()将光标下移,通过getLong(String 列名称)取出 或 getLong(Long 列号)取出(从1开始).
