关于jdbc:JDBC的基本使用

17次阅读

共计 5336 个字符,预计需要花费 14 分钟才能阅读完成。

1. 应用步骤:

  1. 导包
  2. 加载驱动类 class.forName(….)
  3. DriverManager 获取 sql 对象
  4. 写 sql 语句
  5. Statement 与 prepareStatement 不一样的执行 sql 语句,前者是间接 sql 对象 . 执行语句,而后者是预处理,即在创立 sql 对象时,就用 sql 语句,最初在用对象执行操作。

2.JDBCUtils 工具类:

就是把应用步骤的共性,提出来,放在一个类中,这样当前就能间接调用创立 sql 对象的办法就行了。
值得一提的是,如果咱们应用配置文件,扩展性更好,在应用其余数据库时,咱们只须要更改配置文件 properties。获取配置文件能够应用 properties 对象。获取 jar 包的绝对路径能够应用 classLoader 类加载器。这样咱们就不必本人增加门路了。

public class JDBCUtils {
        private static String url;
        private static String user;
        private static String password;
        private static String driver;
        /**
         * 文件的读取,只须要读取一次即可拿到这些值。应用动态代码块
         */
        static{
            // 读取资源文件,获取值。try {
                //1. 创立 Properties 汇合类。Properties pro = new Properties();
    
                // 获取 src 门路下的文件的形式 --->ClassLoader 类加载器
                ClassLoader classLoader = JDBCUtils.class.getClassLoader();
                URL res  = classLoader.getResource("jdbc.properties");
                String path = res.getPath();
                
                //2. 加载文件
                pro.load(new FileReader(path));
    
                //3. 获取数据,赋值
                url = pro.getProperty("url");
                user = pro.getProperty("user");
                password = pro.getProperty("password");
                driver = pro.getProperty("driver");
                //4. 注册驱动
                Class.forName(driver);
            } catch (IOException e) {e.printStackTrace();
            } catch (ClassNotFoundException e) {e.printStackTrace();
            }
        }
    
    
        /**
         * 获取连贯
         * @return 连贯对象
         */
        public static Connection getConnection() throws SQLException {return DriverManager.getConnection(url, user, password);
        }
    
        /**
         * 开释资源
         * @param stmt
         * @param 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();
                }
            }
        }
    
    
        /**
         * 开释资源
         * @param stmt
         * @param conn
         */
        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();
                }
            }
        }
    
    }

3.DBC 管制事务:

在执行 sql 语句时,如果程序执行过程中,产生了异样。比方有两个 sql 语句,一个是转账操作,一个人存转的这笔钱,如果第一个操作完结后产生了异样。那么这笔钱就会不胫而走,所以为了防止这样的状况,能够应用事务。

(1) 具体操作

  1. 开启事务:setAutoCommit(boolean autoCommit):调用该办法设置参数为 false,即开启事务。
  2. 提交事务:commit() 当所有 sql 都执行完提交事务。
  3. 回滚事务:rollback() 在 catch 中回滚事务。
public static void main(String[] args) {
    PreparedStatement pstmt1 = null;
    PreparedStatement pstmt2 = null;
    Connection con = null;


    try {con = JDBCUtils.getConnection();
        // 开启事务
        con.setAutoCommit(false);
        //2.1 张三 - 500
        String sql1 = "update account set balance = balance - ? where id = ?";
        //2.2 李四 + 500
        String sql2 = "update account set balance = balance + ? where id = ?";


        pstmt1 = con.prepareStatement(sql1);
        pstmt2 = con.prepareStatement(sql2);


        //4. 设置参数,sql 语句里的问号
        pstmt1.setDouble(1,500);// 填第一个数据
        pstmt1.setInt(2,1);// 填第二个数据


        pstmt2.setDouble(1,500);
        pstmt2.setInt(2,2);
        //5. 执行 sql
        pstmt1.executeUpdate();
        // 手动制作异样
        int i = 3/0;


        pstmt2.executeUpdate();
        // 提交事务
        con.commit();} catch (SQLException e) {e.printStackTrace();
    } catch (Exception e){
        try {con.rollback();
        } catch (SQLException ex) {ex.printStackTrace();
        }
    } finally{JDBCUtils.close(con,pstmt1);
       JDBCUtils.close(con,pstmt2);
    }
}

4.JDBC 连接池

连接池,就是先创立好一些连贯对象,要用的的时候,间接应用,进步了效率,用完之后,归还给连接池,以便其余的应用。

  1. c3p0 连接池:
    步骤:
  2. 导入 jar 包 (两个) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar,还须要导入数据库驱动 jar 包
  3. 定义配置文件:

    • 名称:c3p0.properties 或者 c3p0-config.xml。
    • 门路:间接将文件放在 src 目录下即可。
  4. 创立外围对象 数据库连接池对象 ComboPooledDataSource
  5. 获取连贯:getConnection

代码:

 //1. 创立数据库连接池对象
      DataSource ds  = new ComboPooledDataSource();
      //2. 获取连贯对象
      Connection conn = ds.getConnection();
  1. druid:

这个是阿里的,性能更好,效率更高。
步骤:

  1. 导入 jar 包 druid-1.0.9.jar
  2. 定义配置文件:

    • 是 properties 模式的
    • 能够叫任意名称,能够放在任意目录下
  3. 加载配置文件。Properties
  4. 获取数据库连接池对象:通过工厂类来获取 DruidDataSourceFactory
  5. 获取连贯:getConnection

代码:

    //3. 加载配置文件
Properties pro = new Properties();
InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(is);
//4. 获取连接池对象
DataSource ds = DruidDataSourceFactory.createDataSource(pro);
//5. 获取连贯
Connection conn = ds.getConnection();

因为代码还是简短,反复率高,所以能够自定义个工具类:

public class JDBCUtils {

                //1. 定义成员变量 DataSource
                private static DataSource ds ;
            
                static{
                    try {
                        //1. 加载配置文件
                        Properties pro = new Properties();
                        pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
                        //2. 获取 DataSource
                        ds = DruidDataSourceFactory.createDataSource(pro);
                    } catch (IOException e) {e.printStackTrace();
                    } catch (Exception e) {e.printStackTrace();
                    }
                }
            
                /**
                 * 获取连贯
                 */
                public static Connection getConnection() throws SQLException {return ds.getConnection();
                }
            
                /**
                 * 开释资源
                 */
                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();
                        }
                    }*/
            
                   close(null,stmt,conn);
                }
            
            
                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();
                        }
                    }
                }
            
                /**
                 * 获取连接池办法
                 */
            
                public static DataSource getDataSource(){return  ds;}
            
            }
  1. Spring JDBC
  • Spring 框架对 JDBC 的简略封装。提供了一个 JDBCTemplate 对象简化 JDBC 的开发

    • 步骤:

      1. 导入 jar 包
      2. 创立 JdbcTemplate 对象。依赖于数据源 DataSource

        • JdbcTemplate template = new JdbcTemplate(ds);
      3. 调用 JdbcTemplate 的办法来实现 CRUD 的操作

        • update(): 执行 DML 语句。增、删、改语句
        • queryForMap(): 查问后果将后果集封装为 map 汇合,将列名作为 key,将值作为 value 将这条记录封装为一个 map 汇合

          • 留神:这个办法查问的后果集长度只能是 1
        • queryForList(): 查问后果将后果集封装为 list 汇合

          • 留神:将每一条记录封装为一个 Map 汇合,再将 Map 汇合装载到 List 汇合中
        • query(): 查问后果,将后果封装为 JavaBean 对象

          • query 的参数:RowMapper

            • 个别咱们应用 BeanPropertyRowMapper 实现类。能够实现数据到 JavaBean 的主动封装
            • new BeanPropertyRowMapper< 类型 >(类型.class)
        • queryForObject:查问后果,将后果封装为对象

          • 个别用于聚合函数的查问
 //2. 定义 sql
 
//1. 获取 JDBCTemplate 对象
private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
String sql = "update emp set salary = 10000 where id = 1001";
//3. 执行 sql
int count = template.update(sql);
System.out.println(count);

这大大简化了咱们 curd 的代码量。

正文完
 0