java攻城狮之路--复习JDBC

1、JDBC中如何获取数据库链接Connection？

 Driver 是一个接口: 数据库厂商必须提供实现的接口. 能从其中获取数据库连接.

 可以通过 Driver 的实现类对象获取数据库连接.

 1. 加入 mysql 驱动

 1). 解压 mysql-connector-java-5.1.7.zip

 2). 在当前项目下新建 lib 目录

 3). 把 mysql-connector-java-5.1.7-bin.jar 复制到 lib 目录下

 4). 右键 build-path , add to buildpath 加入到类路径下.s

几种常用数据库的JDBC URL：

@Test
public void testDriver() throws SQLException {

    //1. 创建一个 Driver 实现类的对象

    Driver driver = new com.mysql.jdbc.Driver();

    //2. 准备连接数据库的基本信息: url, user, password

    String url = "jdbc:mysql://localhost:3306/test";

    Properties info = new Properties();

    info.put("user", "root");

    info.put("password", "1230");

    //3. 调用 Driver 接口的　connect(url, info) 获取数据库连接

    Connection connection = driver.connect(url, info);

    System.out.println(connection);
}

/**
JDBC.properties文件中的内容：

#driver=oracle.jdbc.driver.OracleDriver
#jdbcUrl=jdbc:oracle:thin:@localhost:1521:orcl
#user=scott
#password=java

driver=com.mysql.jdbc.Driver
jdbcUrl=jdbc:mysql://localhost:3306/atguigu
user=root
password=1230
*/

public Connection getConnection() throws Exception{

    String driverClass = null;
    String jdbcUrl = null;
    String user = null;
    String password = null;

    //读取类路径下的 jdbc.properties 文件
    InputStream in = 
            getClass().getClassLoader().getResourceAsStream("jdbc.properties");
    Properties properties = new Properties();
    properties.load(in);
    driverClass = properties.getProperty("driver");
    jdbcUrl = properties.getProperty("jdbcUrl");
    user = properties.getProperty("user");
    password = properties.getProperty("password");

    //通过反射常见 Driver 对象. 
    Driver driver = 
            (Driver) Class.forName(driverClass).newInstance();
    Properties info = new Properties();
    info.put("user", user);
    info.put("password", password);

    //通过 Driver 的 connect 方法获取数据库连接. 

    Connection connection = driver.connect(jdbcUrl, info);
    return connection;
    }

    @Test
    public void testGetConnection() throws Exception{
        System.out.println(getConnection());
    }

解决方案: 把数据库驱动 Driver 实现类的全类名、url、user、password 放入一个

配置文件中, 通过修改配置文件的方式实现和具体的数据库解耦.

    @Test
    public void testDriverManager() throws SQLException, IOException {
        String driverClass = null;
        String jdbcUrl = null;
        String user = null;
        String password = null;
        InputStream in = getClass().getClassLoader().getResourceAsStream(
                "jdbc.properties");
        Properties proper = new Properties();
        proper.load(in);
        driverClass = proper.getProperty("driver");
        jdbcUrl = proper.getProperty("jdbcUrl");
        user = proper.getProperty("user");
        password = proper.getProperty("password");
        Connection connection = DriverManager.getConnection(jdbcUrl, user,
                password);
        System.out.println(connection);

    }

    @Test
    public void testDriverManager() throws ClassNotFoundException, SQLException {
        String driverClass = "com.mysql.jdbc.Driver";
        // String driverClass2 = "oracle.jdbc.driver.OracleDriver";

        String jdbcUrl = "jdbc:mysql://localhost:3306/test";
        // String jdbcUrl2 = "jdbc:oracle:thin:@localhost:1521:orcl";

        String user = "root";
        // String user2 = "scott";

        String password = "123";
        // String password2 = "tiger";
        Class.forName(driverClass);
        Connection connection = DriverManager.getConnection(jdbcUrl, user,
                password);
        System.out.println(connection);
    }

@Test
public void testGetConnection2() throws Exception{
        System.out.println(getConnection2()); 
}
    
public Connection getConnection2() throws Exception{
        //1. 准备连接数据库的 4 个字符串. 
        //1). 创建 Properties 对象
        Properties properties = new Properties();
        
        //2). 获取 jdbc.properties 对应的输入流
        InputStream in = 
                this.getClass().getClassLoader().getResourceAsStream("jdbc.properties");
        
        //3). 加载 2） 对应的输入流
        properties.load(in);
        
        //4). 具体决定 user, password 等4 个字符串. 
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        String jdbcUrl = properties.getProperty("jdbcUrl");
        String driver = properties.getProperty("driver");
        
        //2. 加载数据库驱动程序(对应的 Driver 实现类中有注册驱动的静态代码块.)
        Class.forName(driver);
        
        //3. 通过 DriverManager 的 getConnection() 方法获取数据库连接. 
        return DriverManager.getConnection(jdbcUrl, user, password);
}

2、如何通过 JDBC 向指定的数据表中插入一条记录?
 1. Statement: 用于执行 SQL 语句的对象
 1). 通过 Connection 的 createStatement() 方法来获取
 2). 通过 executeUpdate(sql) 可以执行 SQL 语句.
 3). 传入的 SQL 可以是 INSRET, UPDATE 或 DELETE. 但不能是 SELECT
 2. Connection、Statement 都是应用程序和数据库服务器的连接资源. 使用后一定要关闭.
     需要在 finally 中关闭 Connection 和 Statement 对象.
 3. 关闭的顺序是: 先关闭后获取的. 即先关闭 Statement 后关闭 Connection.

    @Test
    public void testStatement() throws Exception{
        //1. 获取数据库连接
        Connection conn = null;
        Statement statement = null;
        
        try {
            conn = getConnection2();
            
            //3. 准备插入的 SQL 语句
            String sql = null;
            
//            sql = "INSERT INTO customers (NAME, EMAIL, BIRTH) " +
//                    "VALUES('XYZ', 'xyz@atguigu.com', '1990-12-12')";
//            sql = "DELETE FROM customers WHERE id = 1";
            sql = "UPDATE customers SET name = 'TOM' " +
                    "WHERE id = 4";
            System.out.println(sql);
            
            //4. 执行插入. 
            //1). 获取操作 SQL 语句的 Statement 对象: 
            //调用 Connection 的 createStatement() 方法来获取
            statement = conn.createStatement();
            
            //2). 调用 Statement 对象的 executeUpdate(sql) 执行 SQL 语句进行插入
            statement.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            try {
                //5. 关闭 Statement 对象.
                if(statement != null)
                    statement.close();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally{
                //2. 关闭连接
                if(conn != null)
                    conn.close();                            
            }
        }
        
    }

    public void update(String sql){
        Connection conn = null;
        Statement statement = null;
        String sql = null;

        try {
            conn = JDBCTools.getConnection();
            statement = conn.createStatement();
            statement.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            JDBCTools.release(statement, conn);
        }
    }

package com.shellway.jdbc;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/**
 * 操作 JDBC 的工具类. 其中封装了一些工具方法 Version 1
 */
public class JDBCTools {

    public static void release(ResultSet rs, 
            Statement statement, Connection conn) {
        if(rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if (statement != null) {
            try {
                statement.close();
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
    }
    
    /**
     * 关闭 Statement 和 Connection
     * @param statement
     * @param conn
     */
    public static void release(Statement statement, Connection conn) {
        if (statement != null) {
            try {
                statement.close();
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
    }

    /**
     * 1. 获取连接的方法. 通过读取配置文件从数据库服务器获取一个连接.
     * 
     * @return
     * @throws Exception
     */
    public static Connection getConnection() throws Exception {
        // 1. 准备连接数据库的 4 个字符串.
        // 1). 创建 Properties 对象
        Properties properties = new Properties();

        // 2). 获取 jdbc.properties 对应的输入流
        InputStream in = JDBCTools.class.getClassLoader().getResourceAsStream(
                "jdbc.properties");

        // 3). 加载 2） 对应的输入流
        properties.load(in);

        // 4). 具体决定 user, password 等4 个字符串.
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        String jdbcUrl = properties.getProperty("jdbcUrl");
        String driver = properties.getProperty("driver");

        // 2. 加载数据库驱动程序(对应的 Driver 实现类中有注册驱动的静态代码块.)
        Class.forName(driver);

        // 3. 通过 DriverManager 的 getConnection() 方法获取数据库连接.
        return DriverManager.getConnection(jdbcUrl, user, password);
    }

}

3、总结：

1、Connection：代表应用程序和数据库的一个连接.

2、Statement：是用于操作 SQL 的对象.

3、ResultSet：封装 JDBC 的查询结果.

package com.shellway.jdbc;

import java.io.IOException;
import java.io.InputStream;
import java.security.interfaces.RSAKey;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import org.junit.Test;

public class ReviewTest {
    
    /**
     * 1. ResultSet 封装 JDBC 的查询结果.
     */
    @Test
    public void testResultSet(){
        
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;
        
        try {
            //1. 获取数据库连接
            connection = getConnection();
            
            //2. 调用 Connection 对象的 createStatement() 方法获取 Statement 对象
            statement = connection.createStatement();
            
            //3. 准备 SQL 语句
            String sql = "SELECT id, name, email, birth FROM customers";
            
            //4. 发送 SQL 语句: 调用 Statement 对象的  executeQuery(sql) 方法.
            //得到结果集对象 ResultSet
            resultSet = statement.executeQuery(sql);
            
            //5. 处理结果集:
            //5.1 调用 ResultSet 的 next() 方法: 查看结果集的下一条记录是否有效, 
            //若有效则下移指针
            while(resultSet.next()){
                //5.2 getXxx() 方法获取具体的列的值. 
                int id = resultSet.getInt(1);
                String name = resultSet.getString(2);
                String email = resultSet.getString(3);
                Date birth = resultSet.getDate(4);
                
                System.out.println(id);
                System.out.println(name);
                System.out.println(email);
                System.out.println(birth);
                
                System.out.println();
            }
            
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            //6. 关闭数据库资源
            releaseDB(resultSet, statement, connection);
        }
    }
    
    /**
     * 1. Statement 是用于操作 SQL 的对象
     */
    @Test
    public void testStatement(){
        Connection connection = null;
        Statement statement = null;
        
        try {
            //1. 获取数据库连接
            connection = getConnection();
            
            //2. 调用 Connection 对象的 createStatement() 方法获取 Statement 对象
            statement = connection.createStatement();
            
            //3. 准备 SQL 语句
            String sql = "UPDATE customers SET name = 'Jerry' " +
                    "WHERE id = 5";
            
            //4. 发送 SQL 语句: 调用 Statement 对象的  executeUpdate(sql) 方法
            statement.executeUpdate(sql);
            
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            //5. 关闭数据库资源: 由里向外关闭. 
            releaseDB(null, statement, connection);
        }            
    }
    
    public void releaseDB(ResultSet resultSet, Statement statement,
            Connection connection){
        
        if(resultSet != null){
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if(statement != null){
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if(connection != null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    
    @Test
    public void testGetConnection2() throws Exception{
        
        Connection connection = getConnection();
        
        System.out.println(connection); 
    }

    public Connection getConnection() throws IOException,
            ClassNotFoundException, SQLException {
        //0. 读取 jdbc.properties
        /**
         * 1). 属性文件对应 Java 中的 Properties 类
         * 2). 可以使用类加载器加载 bin 目录(类路径下)的文件
         */
        Properties properties = new Properties();
        InputStream inStream = ReviewTest.class.getClassLoader()
                .getResourceAsStream("jdbc.properties");
        properties.load(inStream);
        
        //1. 准备获取连接的 4 个字符串: user, password, jdbcUrl, driverClass
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        String jdbcUrl = properties.getProperty("jdbcUrl");
        String driverClass = properties.getProperty("driverClass");
        
        //2. 加载驱动: Class.forName(driverClass)
        Class.forName(driverClass);
        
        //3. 调用 
        //DriverManager.getConnection(jdbcUrl, user, password)
        //获取数据库连接
        Connection connection = DriverManager
                    .getConnection(jdbcUrl, user, password);
        return connection;
    }
    
    /**
     * Connection 代表应用程序和数据库的一个连接.
     * @throws Exception 
     */
    @Test
    public void testGetConnection() throws Exception{
        //1. 准备获取连接的 4 个字符串: user, password, jdbcUrl, driverClass
        String user = "root";
        String password = "123";
        String jdbcUrl = "jdbc:mysql:///test";
        String driverClass = "com.mysql.jdbc.Driver";
        
        //2. 加载驱动: Class.forName(driverClass)
        Class.forName(driverClass);
        
        //3. 调用 
        //DriverManager.getConnection(jdbcUrl, user, password)
        //获取数据库连接
        Connection connection = DriverManager
                    .getConnection(jdbcUrl, user, password);
        
        System.out.println(connection); 
    }
}

jdbc.properties文件内容：

user=root
password=123
driverClass=com.mysql.jdbc.Driver
jdbcUrl=jdbc:mysql://localhost:3306/test

#user=scott
#password=tiger
#driverClass=oracle.jdbc.driver.OracleDriver
#jdbcUrl=jdbc:oracle:thin:@127.0.0.1:1521:orcl

吾时而躬身自省，自省使知已之不足，知不足而奋起，未为晚也!