java攻城狮之路--复习JDBC

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：

@Testpublic 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=javadriver=com.mysql.jdbc.DriverjdbcUrl=jdbc:mysql://localhost:3306/atguiguuser=rootpassword=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);    }

 1 @Test 2 public void testGetConnection2() throws Exception{ 3         System.out.println(getConnection2());  4 } 5      6 public Connection getConnection2() throws Exception{ 7         //1. 准备连接数据库的 4 个字符串.  8         //1). 创建 Properties 对象 9         Properties properties = new Properties();10         11         //2). 获取 jdbc.properties 对应的输入流12         InputStream in = 13                 this.getClass().getClassLoader().getResourceAsStream("jdbc.properties");14         15         //3). 加载 2） 对应的输入流16         properties.load(in);17         18         //4). 具体决定 user, password 等4 个字符串. 19         String user = properties.getProperty("user");20         String password = properties.getProperty("password");21         String jdbcUrl = properties.getProperty("jdbcUrl");22         String driver = properties.getProperty("driver");23         24         //2. 加载数据库驱动程序(对应的 Driver 实现类中有注册驱动的静态代码块.)25         Class.forName(driver);26         27         //3. 通过 DriverManager 的 getConnection() 方法获取数据库连接. 28         return DriverManager.getConnection(jdbcUrl, user, password);29 }

2、如何通过 JDBC 向指定的数据表中插入一条记录?1. Statement: 用于执行 SQL 语句的对象1). 通过 Connection 的 createStatement() 方法来获取2). 通过 executeUpdate(sql) 可以执行 SQL 语句.3). 传入的 SQL 可以是 INSRET, UPDATE 或 DELETE. 但不能是 SELECT2. 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=rootpassword=123driverClass=com.mysql.jdbc.DriverjdbcUrl=jdbc:mysql://localhost:3306/test

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

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