JDBC

一.JDBC
1.概述
     Java DataBase Connectivity--JAVA数据连接库,是一种用于执行SQL语句的JAVA API,
     可以为多种关系数据库提供统一访问,由一组用JAVA语言编写的类和接口组成.JDBC提供了一种基准,据此可以构建更高级的工具和接口,使用数据库开发人员能够编写数据库应用程序.
2.JDBC原理
     JDBC可以让程序员使用固定的流程和方法,操作不同的数据库;
     核心类和接口:
         Driver接口--用于识别数据库;
         Connection接口--用于连接数据库的会话;
         Statement接口--sql执行者;
         ResultSet接口--sql执行的结果集;

        DriverManager类,用于操作JDBC的工具类,通过这个类的方法,可以注册驱动和获取连接.

Driver 接口(java.sql)
     定义:public interface Driver
     常用方法:
     Connection connect(String url,Properties info)throws SQLException{}:通过指定url与数据库建立连接;
Connection 接口(java.sql)
     定义:public interface Connection extends Wrapper, AutoCloseable
     常用方法:
         void close() throws SQLException{}:关闭资源
         Statement createStatement() throws SQLException{}:创建一个 Statement 对象来将 SQL 语句发送到数据库
         PreparedStatement prepareStatement(String sql) throws SQLException{}:返回一个PerparedStatement对象;

StateMent     接口(java.sql)
     定义:public interface Statement extends Wrapper, AutoCloseable
     常用方法:
         boolean execute(String sql) throws SQLException{}:执行Sql;
         ResultSet executeQuery(String sql) throws SQLException{}:返回查询的结果集;
         int executeUpdate(String sql) throws SQLException{}:执行给定 SQL 语句，该语句可能为 INSERT、UPDATE 或 DELETE 语句，或者不返回任何内容的 SQL 语句（如 SQL DDL 语句）。
ResultSet  接口(java.sql)
     定义:public interface ResultSet extends Wrapper, AutoCloseable
     常用方法:
         void close() throws SQLException{}:关闭资源;
         boolean next() throws SQLException{}:将光标从当前位置向前(下)移一行。
         Object getObject(String columnLabel) throws SQLException{}:以 Java 编程语言中 Object 的形式获取此 ResultSet 对象的当前行中指定列的值。
         Object getObject(int columnIndex) throws SQLException{}:以 Java 编程语言中 Object 的形式获取此 ResultSet 对象的当前行中指定列的值。

DriverManager 类(java.sql)
     定义:public class DriverManager extends Object
     常用方法:
         public static void registerDriver(Driver driver) throws SQLException{}:向 DriverManager 注册给定驱动程序。JAVA1.6之后可自动注册,不必写;
         public static Connection getConnection(String url,String user,String password) throws SQLException{}:试图建立到给定数据库 URL 的连接。

3.使用步骤:
     1)注册驱动;让java代码识别数据库,Driver接口的实现者由数据库生产厂商提供,mysql数据库的驱动类在mysql官网可以直接下载,驱动类导入工程--DriverManager类的registerDriver()方法;
     2)获取连接,创建会话对象:DriverManager 类的getConnection(url,use,password)方法;
     3)获取sql执行者:Connection 接口的 createStatement()方法;
     4)编写sql并执行:Statement 接口的 executeUpdate()或 executeQuery()方法;
     5)处理结果集(主要是查询结果);
     6)释放资源,RESULTSET/STATEMENT/CONNECTION/ 按此顺序关闭资源,全为close()方法;

4.PreparedStatement 接口(java.sql) Statement子类
     注意:该接口的一个实例化对象只能执行一次sql语句!!
     定义:public interface PreparedStatement extends Statement
     常用方法:
         boolean execute() throws SQLException{}:执行Sql后返回一个boolean值,一般不用;
         ResultSet executeQuery() throws SQLException{}:返回查询的结果集;
         int executeUpdate() throws SQLException{}:在此 PreparedStatement 对象中执行 SQL 语句，该语句必须是一个 SQL 数据操作语言（Data Manipulation Language，DML）语句，比如 INSERT、UPDATE 或 DELETE 语句；或者是无返回内容的 SQL 语句，比如 DDL 语句。
         void setObject(int parameterIndex,Object x) throws SQLException{}:使用给定对象设置指定参数的值。parameterIndex:表示sql语句中的第几个占位符,从1开始;X:表示要赋的值;

5.代码演示:以下代码在Eclipse中实现,需导入jar包
     代码1:
   

 /*
     使用JDBC查询数据库中的数据
     1:注册驱动
     2:创建会话对象(道路)
      3:获取sql执行者
     4:编写sql并执行
     5:处理结果集
     6:释放资源(结果集,sql执行,会话对象)
      */
     import java.sql.Connection;
     import java.sql.DriverManager;
     import java.sql.ResultSet;
     import java.sql.Statement;

     public class Demo02 {
         public static void main(String[] args) throws Exception {
             // 使用反射加载类注册驱动--固定路径,需牢记"com.mysql.jdbc.Driver"
             Class.forName("com.mysql.jdbc.Driver");
             // 创建会话对象--本地mysql固定路径,需牢记"jdbc:mysql:///mydb?useSSL=false"
             Connection c = DriverManager.getConnection("jdbc:mysql:///mydb?useSSL=false", "root", "root");//注意SSL警告,若不想显示,添加"?useSSL=false"
             // 创建执行者
            Statement st = c.createStatement();
             // 编写sql语句并执行
            String sql = "SELECT * FROM category";
             ResultSet set = st.executeQuery(sql);
             // 处理结果集
            while (set.next()) {
                 Object cid = set.getObject("cid");
                 Object cname = set.getObject("cname");
                 System.out.println(cid + "----" + cname);
             }
             // 关闭资源--顺序:ResultSet/Statement/Connection
             set.close();
             st.close();
             c.close();
        }
     }

    
     代码2:自定义JDBC工具类--思考面向对象封装的思想
  

  import java.sql.Connection;
     import java.sql.DriverManager;
     import java.sql.ResultSet;
     import java.sql.SQLException;
     import java.sql.Statement;
     /*
      * 使用JDBC时,注册,获取连接,关闭资源三个操作为固定模式,可封装成类
     * */
     public class MyJDBCUtils {
         // 定义成员变量--由于Mysql Driver类 路径-数据库URL-用户名-密码一般固定,因此可设为成员变量,并加final修饰
        private static final String path = "com.mysql.jdbc.Driver";
         private static final String url = "jdbc:mysql://localhost:3306/mydb?useSSL=false";
         private static final String user = "root";
         private static final String password = "root";
         // 注册方法，由于只注册一次,因此使用静态代码块
        static {
             try {
                 Class.forName(path);
             } catch (ClassNotFoundException e) {
                 e.printStackTrace();
                 throw new RuntimeException("记得要先导包~");
             }
         }
         // 获取连接,返回Connection类的实例对象
        public static Connection getConnection() {
             try {
                 Connection c = DriverManager.getConnection(url, user, password);
                 return c;
             } catch (SQLException e) {
                 e.printStackTrace();
                 throw new RuntimeException("路径对吗?数据库创建了吗?密码对吗?");
             }
         }
         // 关闭资源--顺序Result/statement/connection
         public static void close(ResultSet r, Statement st, Connection c) {
             if (c != null) {
                 try {
                     c.close();
                 } catch (SQLException e) {
                     e.printStackTrace();
                     throw new RuntimeException("连接关闭异常!");
                 }
             }

             if (st != null) {
                 try {
                     st.close();
                 } catch (SQLException e) {
                     e.printStackTrace();
                     throw new RuntimeException("执行关闭异常!");
                 }
             }

             if (r != null) {
                 try {
                     r.close();
                 } catch (SQLException e) {
                     e.printStackTrace();
                     throw new RuntimeException("结果集关闭异常!");
                 }
             }
         }
     }

    
     代码3:利用自定义工具类完成CRUD
    

import huguangqin.com.cnblogs.MyJDBCUtils.MyJDBCUtils;
     import java.sql.Connection;
     import java.sql.ResultSet;
     import java.sql.SQLException;
     import java.sql.Statement;
     /*
      * 利用工具类完成CRUD
      * */
     public class Demo01 {
        public static void main(String[] args) throws SQLException {
             // 注册驱动-工具类,并获取连接-工具类-(无需注册,由于类里设置了静态代码块,获取连接调用该类会自动注册)
             Connection c = MyJDBCUtils.getConnection();

             // 获取执行者Statement
             Statement st = c.createStatement();

             // 编写sql,并执行
            // 插入数据
            String insertSQL = "INSERT INTO category(cid,cname) VALUES(7,'花卷'),(8,'包子')";
             // 执行插入
            int i = st.executeUpdate(insertSQL);
             // 查询数据
            String querySQL = "SELECT * FROM category";
             // 执行查询
            ResultSet set = st.executeQuery(querySQL);
             // 处理结果集-ResultSet
             while (set.next()) {
                 Object cid = set.getObject("cid");
                 Object cname = set.getObject("cname");
                 System.out.println(cid + "===" + cname);
             }
             // 关闭资源-工具类
            MyJDBCUtils.close(set, st, c);
         }
     }

代码4://面向Connection 获取PreparedStatement对象,预处理sql对象的每条语句,防止SQL注入攻击

import huguangqin.com.cnblogs.MyJDBCUtils.MyJDBCUtils;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;

public class PreparedStatementDemo {
     public static void main(String[] args) throws SQLException {
         // 利用自定义工具类获取连接,同时完成注册驱动
        Connection c = MyJDBCUtils.getConnection();
         // 使用PreparedStatement向表中插入三行数据
        String insertSQL = "INSERT INTO user(name,password) VALUES(?,?)";
         // 面向Connection 获取PreparedStatement对象
        PreparedStatement pst = c.prepareStatement(insertSQL);
         // 设置实际参数
        pst.setObject(1, "a");
         pst.setObject(2, "a");
         // 执行(PreparedStatement的一个实例化对象只能执行一次sql)
         int i = pst.executeUpdate();

        // 查询
        String querySQL = "SELECT * FROM USER WHERE name = ?";
         // 面向Connection获取PreparedStatement对象
        PreparedStatement pst1 = c.prepareStatement(querySQL);
         pst1.setObject(1, "a");
         ResultSet set = pst1.executeQuery();
         // 处理结果集
        while (set.next()) {
             Object name = set.getObject("name");
             Object password = set.getObject("password");
             System.out.println(name + "====" + password);
         }
     }
 }