JDBC（mysql和Oracle两种方法）

清疚 2024-03-31 15:04 51阅读 0赞

## JDBC ##

JDBC API是一个Java API，可以访问任何类型表列数据，特别是存储在关系数据库中的数据。JDBC代表Java数据库连接。

JDBC库中所包含的API通常与数据库使用于：

*  连接到数据库
 *  创建SQL或MySQL语句
 *  在数据库中执行SQL或MySQL查询
 *  查看和修改数据库中的数据记录

用mysql和Oracle来进行教程，因为我电脑里面既有Oracle也有MySQL

## 1.开发步骤 ##

1.  注册驱动
2.  获取连接
3.  获得语句执行平台
4.  执行sql语句
5.  处理结果
6.  释放对象

//mysql的
    public class Demo01 {
        public static void main(String[] args) throws ClassNotFoundException, SQLException {
            // 注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            //获取链接
            String url = "jdbc:mysql://localhost:3306/test";
            String user = "root";
            String password = "123456";
            Connection connection = DriverManager.getConnection(url, user, password);
            //获取执行者对象
            Statement statement = connection.createStatement();
            //执行sql语句
            String sql = "select username,password from user";
            ResultSet resultSet = statement.executeQuery(sql);
            //处理结果
            while (resultSet.next()){
                String usernameStr=resultSet.getString("username");
                String passwordStr=resultSet.getString("password");
                System.out.println(usernameStr+"--"+passwordStr);
            }
            // 关闭资源
            resultSet.close();
            statement.close();
            connection.close();
        }
    }

package oracle;
    
    import java.sql.*;
    
    public class Demo01 {
        public static void main(String[] args) throws ClassNotFoundException, SQLException {
            // 注册驱动
            Class.forName("oracle.jdbc.driver.OracleDriver");
            String url = "jdbc:oracle:thin:@localhost:1521:orcl";
            String user = "scott";
            String password = "tiger";
            Connection connection = DriverManager.getConnection(url, user, password);
            Statement statement = connection.createStatement();
            String sql = "select username,password from users";
            ResultSet resultSet = statement.executeQuery(sql);
            while (resultSet.next()){
                String usernameStr=resultSet.getString("username");
                String passwordStr=resultSet.getString("password");
                System.out.println(usernameStr+"--"+passwordStr);
            }
            resultSet.close();
            statement.close();
            connection.close();
        }
    }

## 2.工具类 ##

package oracle;
    
    import java.sql.*;
    
    public class DBUtils {
        // 重构：一旦发现代码用起来不是很爽的时候，一直有重复动作，必须想把饭抽取出来一个新的
        public DBUtils() {
        }
    
        public static Connection conn;
    
        // 静态块：在类初始化之后，会加载一次
        // 一般情况，我们会将一些常用的数据，放在静态块中进行加载
        // 加载完成之后，后面如果想要用的话，直接就可以用
        // 优点是，只会创建一次，不会重复创建良妃性能
        static {
            try {
                // 1.注册驱动
                Class.forName("oracle.jdbc.driver.OracleDriver");
                // 2.获取连接：数据库地址、用户名、密码 Connection
                String url = "jdbc:oracle:thin:@localhost:1521:orcl";
                String user = "scott";
                String password = "tiger";
                conn = DriverManager.getConnection(url, user, password);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 获取 Connection 对象
         */
        public static Connection getConnection() {
            return conn;
        }
    
        /**
         * 释放资源
         */
        public static void close(Statement stmt, Connection conn) {
            // 思路：在关闭资源之前，先要判断，到底有没有用到这个资源
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
        public static void close(ResultSet rs, Statement stmt, Connection conn) {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
    }

package mysql;
    
    import java.sql.*;
    
    public class DBUtils {
        // 重构：一旦发现代码用起来不是很爽的时候，一直有重复动作，必须想把饭抽取出来一个新的
        public DBUtils() {
        }
    
        public static Connection conn;
    
        // 静态块：在类初始化之后，会加载一次
        // 一般情况，我们会将一些常用的数据，放在静态块中进行加载
        // 加载完成之后，后面如果想要用的话，直接就可以用
        // 优点是，只会创建一次，不会重复创建良妃性能
        static {
            try {
                // 1.注册驱动
                Class.forName("com.mysql.jdbc.Driver");
                // 2.获取连接：数据库地址、用户名、密码 Connection
                String url = "jdbc:mysql://localhost:3306/test";
                String user = "root";
                String password = "123456";
                conn = DriverManager.getConnection(url, user, password);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 获取 Connection 对象
         */
        public static Connection getConnection() {
            return conn;
        }
    
        /**
         * 释放资源
         */
        public static void close(Statement stmt, Connection conn) {
            // 思路：在关闭资源之前，先要判断，到底有没有用到这个资源
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
        public static void close(ResultSet rs, Statement stmt, Connection conn) {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
    }

测试

package oracle;
    
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class DBUtilsTest {
        public static void main(String[] args) throws SQLException {
            Connection connection = DBUtils.getConnection();
            String sql = "select * from users";
            Statement statement = connection.createStatement();
            ResultSet resultSet = statement.executeQuery(sql);
            while (resultSet.next()){
                String usernameStr=resultSet.getString("username");
                String passwordStr=resultSet.getString("password");
                System.out.println(usernameStr+"--"+passwordStr);
            }
            DBUtils.close(resultSet,statement,connection);
        }
    }