java学习笔记（三十五）JDBC

1 JDBC入门

之前操作mysql数据库： 1）使用mysql客户端工具 2）使用客户端连接mysql服务器 3）发送sql语句到mysql服务器，执行

1.2 什么是JDBC？ 使用java程序发送sql语句到数据库服务器端执行，这叫用到了JDBC技术 jdbc是Oracle-Sun公司设计的一套专门用于java程序操作数据库的接口。 1.3 使用jdbc发送sql条件 连接mysql数据库：

数据库主机 端口 数据库用户名 数据库密码 连接的数据库

1.4 JDBC的核心API Driver接口： 数据库驱动程序的接口，所有具体数据库厂商需要的驱动程序需要实现此接口。

Connection connect(String url, Properties info) 用于获取数据库连接

练习：演示三种连接数据库的方式

import java.sql.Connection; import java.sql.Driver; import java.sql.DriverManager; import java.sql.SQLException; import java.util.Properties; public class DriverDemo { private static String url = "jdbc:mysql://localhost:3306/day20"; //jdbc协议:mysql协议://主机地址:端口号/需要连接的数据库名称 private static String user = "root"; private static String password="root"; public static void main(String[] args) throws Exception { /** * java程序连接mysql数据库 * 1.mysql数据库的主机地址 * 2.端口号 * 3.用户名 * 5.密码 * 6.需要连接的数据库 * * 需求：先使用java程序连接我们的数据库，需要一个连接对象Connection */ //conn1(); //conn2(); conn3(); } private static void conn3() throws Exception { //注册驱动，mysql驱动程序的Driver实现类已经帮我们在静态代码块中注册好了驱动， //只需要将Driver实现类加载到我们的内存中，static代码块就会自动执行，驱动也就自动注册了 //注册驱动 Class.forName("com.mysql.jdbc.Driver"); //获取java连接数据库的对象 Connection conn = DriverManager.getConnection(url, user, password); //打印这个连接对象 System.out.println(conn); } private static void conn2() throws Exception { //使用驱动管理类，连管理我们的驱动程序，并获取连接 //1.注册驱动 //public static void registerDriver(Driver driver)throws SQLException Driver driver = new com.mysql.jdbc.Driver(); DriverManager.registerDriver(driver); //获取连接 //public static Connection getConnection(String url,String user,String password)throws SQLException Connection conn = DriverManager.getConnection(url, user, password); //打印这里数据库连接 System.out.println(conn); } //直连 private static void conn1() throws SQLException { //创建一个驱动类对象Driver Driver driver = new com.mysql.jdbc.Driver(); //获取java连接数据库的连接 //Connection connect(String url, Properties info)throws SQLException //创建一个properties集合 Properties prop = new Properties(); prop.setProperty("user", user); prop.setProperty("password", password); Connection conn = driver.connect(url, prop); //打印这个连接对象，如果连接对象不为空，就说明我们已经成功获取到了连接对象 System.out.println(conn); } }

写一个jdbc工具类来完成连接数据库和释放资源

import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class JDBCUtil { private static String url = "jdbc:mysql://localhost:3306/day20"; private static String user = "root"; private static String password = "root"; static{ //随着类的加载而夹在 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //获取连接 public static Connection getConn(){ //注册驱动 try { Connection conn = DriverManager.getConnection(url, user, password); return conn; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); throw new RuntimeException(); } } //释放资源 public static void close(Connection conn,Statement stmt,ResultSet rs){ if (conn!=null) { try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (stmt!=null) { try { stmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (rs!=null) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }

Statement接口：用于执行静态 SQL 语句

int executeUpdate(String sql) 执行更新操作的sql语句 （create/alter/drop) DDL语句 和(insert/update/delete）DML语句 ResultSet executeQuery(String sql) 执行查询操作的sql语句和(select)（DQL查询语句）

ResultSet接口：结果集对象。 存储所有数据库查询的结果，用该对象进行数据遍历。

boolean next() ： 把光标移动到下一行。如果下一行有数据，返回true，如果没有下一行数据，返回false。 getXXX（列索引|列字段名称）： 获取字段的数据

练习：使用jDBC创建一张学生表

import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; public class Demo { public static void main(String[] args){ Connection conn = null; Statement stmt = null; try { conn = JDBCUtil.getConn(); //创建语句执行者 stmt = conn.createStatement(); //int executeUpdate(String sql) //throws SQLException执行给定 SQL 语句， //该语句可能为 INSERT、UPDATE 或 DELETE 语句，或者不返回任何内容的 SQL 语句（如 SQL DDL 语句）。 String sql = "CREATE TABLE student("+ "id INT,"+ "NAME VARCHAR(20),"+ "age INT"+ ");"; //使用语句执行者执行创建的sql语句 int count = stmt.executeUpdate(sql); //打印一下影响的结果 System.out.println(count); } catch (Exception e) { e.printStackTrace(); throw new RuntimeException(); }finally{ //释放资源 JDBCUtil.close(conn, stmt, null); }

练习：使用jdbc查询学生表中的数据

import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import com.jdbc.Util.JDBCUtil; public class Demo3 { public static void main(String[] args) { //定义一个连接对象和一个语句执行者 Connection conn =null; Statement stmt = null; ResultSet rs = null; try{ conn = JDBCUtil.getConn(); //定义sql String sql = "SELECT * FROM student;"; //获取语句执行者对象 stmt = conn.createStatement(); //执行DQL查询语句 //ResultSet executeQuery(String sql) //throws SQLException执行给定的 SQL 语句，该语句返回单个 ResultSet 对象。 rs = stmt.executeQuery(sql); //ResultSet是一个结果集 while (rs.next()) System.out.println(rs.getInt(1)+"--"+rs.getString(2)+"--"+rs.getInt(3)); }*/ //使用字段名称获取字段的每一个数据 while (rs.next()) { //当我们使用字段名称去获取字段数据的时候，字段名称是不区分大小写 System.out.println(rs.getInt("ID")+"--"+rs.getString("NAME")+"--"+rs.getInt("AGE")); } }catch(Exception e){ e.printStackTrace(); }finally{ //释放资源 JDBCUtil.close(conn, stmt, rs); } } }

PreparedStatement接口：用于执行预编译的 SQL 语句（是Statement的子接口）

int executeUpdate() 执行更新操作的sql语句 ResultSet executeQuery() 执行查询操作的sql语句 import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import com.jdbc.Util.JDBCUtil; public class Demo { public static void main(String[] args) { //testInsert();//插入 //testUpdate();//修改 //testDelete();//删除 testSelect();//查询 } private static void testSelect() { Connection conn =null; PreparedStatement stmt = null; ResultSet rs = null; try{ //获取连接 conn = JDBCUtil.getConn(); //定义预编译sql String sql = "SELECT * FROM student WHERE id=?;"; //获取预编译sql对象 stmt = conn.prepareStatement(sql); //给问好赋值 stmt.setInt(1, 3); //发送参数并执行sql语句 //ResultSet executeQuery()throws SQLException在此 //PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象。 rs = stmt.executeQuery(); //遍历结果集 while (rs.next()) { System.out.println(rs.getInt("id")+"--"+rs.getString("name")+"--"+rs.getInt("age")); } }catch(Exception e){ e.printStackTrace(); }finally{ JDBCUtil.close(conn, stmt, rs); } } private static void testDelete() { Connection conn =null; PreparedStatement stmt = null; try{ conn = JDBCUtil.getConn(); //写一个参数化的sql String sql = "DELETE FROM student WHERE id=?;"; //获取预编译的sql对象 stmt = conn.prepareStatement(sql); //给？设置参数 stmt.setInt(1, 2); //发送参数并执行sql int count = stmt.executeUpdate(); System.out.println(count); }catch(Exception e){ e.printStackTrace(); }finally{ JDBCUtil.close(conn, stmt, null); } } private static void testUpdate() { Connection conn =null; PreparedStatement stmt = null; try{ conn = JDBCUtil.getConn(); String sql = "UPDATE student SET NAME=? WHERE id=?;"; //执行预编译sql stmt = conn.prepareStatement(sql); //给？赋值 stmt.setString(1, "张学友"); stmt.setInt(2, 5); //发送参数到数据库服务器，并执行sql,将执行结果返回 int count = stmt.executeUpdate(); System.out.println(count); }catch(Exception e){ e.printStackTrace(); }finally{ JDBCUtil.close(conn, stmt, null); } } private static void testInsert() { //定义连接对象和预编译sql对象 Connection conn = null; PreparedStatement stmt = null; try{ //获取连接 conn = JDBCUtil.getConn(); //PreparedStatement prepareStatement(String sql) //throws SQLException创建一个 PreparedStatement 对象来将参数化的 SQL 语句发送到数据库。 String sql = "INSERT INTO student VALUES(?,?,?);";//参数化的sql,动态sql stmt = conn.prepareStatement(sql);//需要一个预编译的sequel语句，将sq发送到数据库端，检查sql语法及用户权限等信息 //给之前参数化的sql语句设置参数 //两个参数：1：是给第几个？设置数据 2：给？设置的数据 stmt.setInt(1, 5); stmt.setString(2, "黎明"); stmt.setInt(3, 60); //int executeUpdate()throws SQLException int count = stmt.executeUpdate(); System.out.println(count); }catch(Exception e){ e.printStackTrace(); }finally{ //释放资源 JDBCUtil.close(conn, stmt, null); } } }

CallableStatement接口：用于执行 SQL 存储过程的接口（是PreparedStatement的子接口）

ResultSet executeQuery() 执行存储过程的sql语句 import java.sql.CallableStatement; import java.sql.Connection; import java.sql.ResultSet; import com.jdbc.Util.JDBCUtil; public class Demo { public static void main(String[] args) { //执行带有输入参数存储过程 //testIn(); //执行带有输出参数的存储过程 testOut(); } private static void testOut() { Connection conn =null; CallableStatement stmt = null; ResultSet rs = null; try{ conn = JDBCUtil.getConn(); String sql = "CALL pro_QueryNameById(?,?);"; stmt = conn.prepareCall(sql); //给问号赋值 stmt.setInt(1, 2); //如果存储过程带有输出参数的时候，首先需要注册，输出参数的类型 //void registerOutParameter(int parameterIndex,int sqlType) stmt.registerOutParameter(2, java.sql.Types.VARCHAR); //发送参数并执行sql stmt.executeQuery(); //从stmt中取出输出参数的结果 System.out.println(stmt.getString(2)); }catch(Exception e){ e.printStackTrace(); }finally{ //释放资源 JDBCUtil.close(conn, stmt, rs); } } private static void testIn() { Connection conn =null; CallableStatement stmt = null; ResultSet rs = null; try{ conn = JDBCUtil.getConn(); String sql = "CALL pro_QueryById(?);"; stmt = conn.prepareCall(sql); //给问号设置值 stmt.setInt(1, 2); //发送参数并执行sql,只能调用excuteQuery() rs = stmt.executeQuery(); if (rs.next()) { System.out.println(rs.getInt(1)+"--"+rs.getString(2)); } }catch(Exception e){ e.printStackTrace(); }finally{ //释放资源 JDBCUtil.close(conn, stmt, rs); } } }