【无标题】

书接上回，下面是 JDBC 原理详解

三、JDBC-API详解+实战

JDBC API是Java语言访问数据库的标准API，它定义了一组类和接口，用于封装数据库访问的细节。主要包括以下几类：

1、DriverManager驱动管理对象
(1)注册驱动：
注册给定的驱动程序：staticvoid registerDriver(Driver driver);在com.mysql.jdbc.Driver类中存在静态代码块；
写代码有固定写法：Class.forName(“com.mysql.jdbc.Driver”);

(2)获取数据库连接对象
具体实现是通过：DriverManager.getConnection（url,username,password）;

2、Connection数据库连接对象
(1)创建sql执行对象

conn.createStatement();

(2)可以执行事务的提交，回滚操作

conn.rollback();conn.setAutoCommit(false);

3、Statement执行sql语句的对象
用于向数据库发送要执行的sql语句（增删改查），其中有两个重要方法：

executeUpdate(String sql)
executeQuery(String sql)
前者用于DML操作，后者用于DQL操作。

4、ResultSet结果集对象
打印输出时判断结果集是否为空，rs.next()
若知字段类型可使用指定类型如,rs.getInt()获取数据

四、提取工具类并完成增删改查操作
在上面介绍了可以通过JDBC对数据库进行增删改查操作，但是如果每次对数据库操作一次都要重新加载一次驱动，建立连接等重复性操作的话，会造成代码的冗余。

因此下面通过封装一个工具类来实现对数据库的增删改查操作。

1、建立配置文件db.properties文件
properties文件是Java支持的一种配置文件类型(所谓支持是因为Java提供了properties类,来读取properties文件中的信息)。记得一定要将此文件直接放在src目录下！！！不然后面执行可能找不到此配置文件！！

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=lcl403020

2、建立工具类JdbcUtils.java
有了这个工具类，之后的增删改查操作可直接导入这个工具类完成获取连接，释放资源的操作，很方便，接着往下看。

package jdbcFirstDemo.src.lesson02.utils;
import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
public class JdbcUtils {
   private static String driver=null;
   private static String url=null;
   private static String username=null;
   private static String password=null;
   static  {
      try{
      InputStream in=JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");           Properties properties=new Properties();
      properties.load(in);
      

            driver=properties.getProperty("driver");
            url=properties.getProperty("url");
            username=properties.getProperty("username");
            password=properties.getProperty("password");
            //驱动只需要加载一次
            Class.forName(driver);
         } catch (IOException e) {
            throw new RuntimeException(e);
         } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
            }
            }
            //获取连接
            public static Connection getConnection() throws SQLException {
                return DriverManager.getConnection(url,username,password);
            }
            //释放连接资源
            public static void release(Connection conn, Statement st, ResultSet rs)  {
               if(rs!=null){
                  try{
                      rs.close();
                  } catch (SQLException e) {
                      throw new RuntimeException(e);
                }
            }
            

        if(st!=null){
           try {
               st.close();
           } catch (SQLException e) {
              throw new RuntimeException(e);
              }
            } 
            if(conn!=null){
              try {
                  conn.close();
              } catch (SQLException e) {
                 throw new RuntimeException(e);
                 } 
           }

       }
    }

3、 插入数据（DML）

package jdbcFirstDemo.src.lesson02;
import jdbcFirstDemo.src.lesson02.utils.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestInsert {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        try{
            conn= JdbcUtils.getConnection();
            st=conn.createStatement();
            String sql="insert into users  (id, name, password, email, birthday) VALUES (7,'cll',406020,'30812290','2002-03-03 10:00:00')";
            int i=st.executeUpdate(sql);
            if(i>0){
                System.out.println("插入成功！");
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
        finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

运行结果：

4、修改数据（DML）

package jdbcFirstDemo.src.lesson02;
import jdbcFirstDemo.src.lesson02.utils.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestUpdate {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        try{
            conn= JdbcUtils.getConnection();
            st=conn.createStatement();
            String sql="update users set name='haha' where id=2";
            int i=st.executeUpdate(sql);
            if(i>0){
                System.out.println("修改成功！");
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
        finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

5、 删除数据（DML）

package jdbcFirstDemo.src.lesson02;
import jdbcFirstDemo.src.lesson02.utils.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestDelete {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        try{
            conn= JdbcUtils.getConnection();
            st=conn.createStatement();
            String sql="delete from users where id=1";
            int i=st.executeUpdate(sql);
            if(i>0){
                System.out.println("删除成功！");
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
        finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

运行结果：删除掉了id=1的那一条数据

6、 查询数据(DQL)

package jdbcFirstDemo.src.lesson02;
import jdbcFirstDemo.src.lesson02.utils.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestQuery {
    public static void main(String[] args) throws SQLException {
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        conn= JdbcUtils.getConnection();
        st=conn.createStatement();
        //sql
        String sql="select * from users";
        rs=st.executeQuery(sql);
        while (rs.next()){
            System.out.println(rs.getString("name"));
        }
    }
}