JDBC详解

Posted 2021-01-15 yuyangcoder

JDBC是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。

加载JDBC驱动程序 → 建立数据库连接Connection → 创建执行SQL的语句Statement → 处理执行结果ResultSet → 释放资源

JDBC常用接口：

 

1.Driver接口

 

　    在编程中要连接数据库，必须先装载特定厂商的数据库驱动程序，不同的数据库有不同的装载方法。如：

 

　　mysql驱动：Class.forName("com.mysql.jdbc.Driver");

 

　　Oracle驱动：Class.forName("oracle.jdbc.driver.OracleDriver");

        方式一：Class.forName(“com.MySQL.jdbc.Driver”);
　　方式二：DriverManager.registerDriver(com.mysql.jdbc.Driver);

2.Connection接口

　　Connection与特定数据库的连接（会话），在连接上下文中执行sql语句并返回结果。

　　连接MySql数据库：Connection conn = DriverManager.getConnection("jdbc:mysql://host:port/database", "user", "password");

　　连接Oracle数据库：Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@host:port:database", "user", "password");

　　连接SqlServer数据库：Connection conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://host:port; DatabaseName=database", "user", "password");

　　常用方法：

• createStatement()：创建向数据库发送sql的statement对象。
• prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
• prepareCall(sql)：创建执行存储过程的callableStatement对象。
• setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
• commit() ：在链接上提交事务。
• rollback() ：在此链接上回滚事务。

3.Statement接口

　　用于执行静态SQL语句并返回它所生成结果的对象。

　　三种Statement类：

• Statement：由createStatement创建，用于发送简单的SQL语句（不带参数）。
• PreparedStatement ：继承自Statement接口，由preparedStatement创建，用于发送含有一个或多个参数的SQL语句。PreparedStatement对象比Statement对象的效率更高，并且可以防止SQL注入，所以我们一般都使用PreparedStatement。
• CallableStatement：继承自PreparedStatement接口，由方法prepareCall创建，用于调用存储过程。

　　常用Statement方法：

• executeQuery(String sql)：运行select语句，返回ResultSet结果集。
• executeUpdate(String sql)：运行insert/update/delete操作，返回更新的行数。
• addBatch(String sql) ：把多条sql语句放到一个批处理中。
• executeBatch()：向数据库发送一批sql语句执行。
• execute(String sql):运行语句，返回是否有结果集

4.ResultSet接口

　　ResultSet提供检索不同类型字段的方法，常用的有：

• getString(int index)、getString(String columnName)：获得在数据库里是varchar、char等类型的数据对象。
• getFloat(int index)、getFloat(String columnName)：获得在数据库里是Float类型的数据对象。
• getDate(int index)、getDate(String columnName)：获得在数据库里是Date类型的数据。
• getBoolean(int index)、getBoolean(String columnName)：获得在数据库里是Boolean类型的数据。
• getObject(int index)、getObject(String columnName)：获取在数据库里任意类型的数据。

　　ResultSet还提供了对结果集进行滚动的方法：

• next()：移动到下一行
• Previous()：移动到前一行
• absolute(int row)：移动到指定行
• beforeFirst()：移动resultSet的最前面。
• afterLast() ：移动到resultSet的最后面。

使用后依次关闭对象及连接：ResultSet → Statement → Connection

数据库连接池技术

• 由于我们要对数据库频繁地进行操作,每进行一次连接操作就要获取一个conntection连接,每次使用完毕后要全部关闭资源,这样的话我们可以使用数据库连接池技术

优点:

1. 资源重用:避免重复创建,释放连接,大量节约性能开销
2. 更快的响应:在连接池初始化的过程中,往往已经创建了若干数据库连接置于连接池中备用。此时连接的初始化工作均已完成。对于业务请求处理而言，直接利用现有可用连接，避免了数据库连接初始化和释放过程的时间开销，从而减少了系统的响应时间。
3. 新的资源分配手段: 对于多应用共享同一数据库的系统而言，可在应用层通过数据库连接池的配置，实现某一应用最大可用数据库连接数的限制，避免某一应用独占所有的数据库资源
4. 统一的连接管理,避免数据库连接泄露:  在较为完善的数据库连接池实现中，可根据预先的占用超时设定，强制回收被占用连接，从而避免了常规数据库连接操作中可能出现的资源泄露。
5. 创建的数据库连接池
   • DBCP:由于性能问题,已经很少使用了
   • C3P0:目前在很多项目中都在使用
   • Druid(阿里巴巴):阿里巴巴开源的一个数据库连接池

下面我们示范常用的C3p0的使用

• 导入jar包c3p0-0.9.1.2.jar
• 在项目src目录下新建c3p0.properties

 

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

 

　

//创建一个数据库连接池ComboPooledDataSource ds = new ComboPooledDataSource();
QueryRunner qr = new QueryRunner(DataSourceUtils.getDataSource());
//通过接口可以执行查询或者更新,修改操作
　　qr.update(sql); //返回受影响的行数
　　qr.query(sql, null); //返回各种类型

public Category getById(String cid) throws Exception {
      QueryRunner qr = new QueryRunner(DataSourceUtils.getDataSource());
      String sql = "select * from category where cid = ?";       
      return qr.query(sql, new BeanHandler<>(Category.class), cid);
    }

//封装成list
public List<Category> findAll() throws Exception {
        QueryRunner qr = new QueryRunner(DataSourceUtils.getDataSource());
        String sql = "select * from category";
        List<Category> list = qr.query(sql, new BeanListHandler<>(Category.class));
        return list;
    }

/**
     * 查询数据总条数   返回单条数据
     */
    @Override
    public Integer getTotalSize() throws Exception {
        // 创建查询接口
        QueryRunner qr = new QueryRunner(DataSourceUtils.getDataSource());
        String sql = "select count(*) from links";
        return ((Long) qr.query(sql, new ScalarHandler())).intValue();
    }