五、Statement对象说明

Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。

Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sql语句，executeUpdate执行完后，将会返回一个整数（即增删改语句导致了数据库几行数据发生了变化）。

Statement.executeQuery方法用于向数据库发送查询语句，executeQuery方法返回代表查询结果的ResultSet对象。

1.CRUD操作-CREATE

使用executeUpdate(String sql)方法完成数据添加操作，示例操作：

Statement st = conn.createStatement();
String sql = "insert into user(….) values(…..) ";
int num = st.executeUpdate(sql);
if(num>0){
  System.out.println("插入成功！！！");
}

2.CRUD操作-DELETE

使用executeUpdate(String sql)方法完成数据修改操作，示例操作：

Statement st = conn.createStatement();
String sql = "update user set name='' where name=''";
int num = st.executeUpdate(sql);
if(num>0){
  System.out.println(“修改成功！！！");
}

3.CRUD操作-UPDATE

使用executeQuery(String sql)方法完成数据查询操作，示例操作：

Statement st = conn.createStatement();
String sql = "select * from user where id=1";
ResultSet rs = st.executeUpdate(sql);
while(rs.next()){
  //根据获取列的数据类型，分别调用rs的相应方法映射到java对象中
}

4.CRUD操作-READ

使用executeQuery(String sql)方法完成数据查询操作，示例操作：

Statement st = conn.createStatement();
String sql = "select * from user where id=1";
ResultSet rs = st.executeUpdate(sql);
while(rs.next()){
  //根据获取列的数据类型，分别调用rs的相应方法映射到java对象中
}

七、SQL注入问题

通过巧妙的技巧来拼接字符串，造成SQL短路，从而获取数据库数据
这是一个比较严重的问题，需要解决，可采用PreparedStatement对象进行解决

login("zhangsan","123456"); // 正常登陆
login("'or '1=1","123456"); // SQL 注入

八、PreparedStatement对象说明

PreperedStatement是Statement的子类，它的实例对象可以通过调用Connection.preparedStatement()方法获得，相对于Statement对象而言：PreperedStatement可以避免SQL注入的问题。

Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。

PreparedStatement可对SQL进行预编译，从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数，允许使用占位符的形式进行替换，简化sql语句的编写。

避免SQL 注入：

public static void login(String username,String password){
    Connection conn = null;
    PreparedStatement st = null;
    ResultSet rs = null;
    try{
      conn = JdbcUtils.getConnection();
      // select * from users where name='' or '1=1' and password =
'123456'
      String sql = "select * from users where name=? and password=?";
      st = conn.prepareStatement(sql);
      st.setString(1,username);
      st.setString(2,password);
      rs = st.executeQuery();
      while(rs.next()){
        System.out.println(rs.getString("name"));
        System.out.println(rs.getString("password"));
     }
   }catch (Exception e) {
      e.printStackTrace();
   }finally{
      JdbcUtils.release(conn, st, rs);
   }
 }

九、JDBC操作事务

1.事务概念

事务指逻辑上的一组操作，组成这组操作的各个单元，要不全部成功，要不全部不成功。

2.事务的ACID 原则

原子性(Atomic)

整个事务中的所有操作，要么全部完成，要么全部不完成，不可能停滞在中间某个环节。事务在执行过程中发生错误，会被回滚（ROLLBACK）到事务开始前的状态，就像这个事务从来没有执行过一样。

一致性(Consist)

一个事务可以封装状态改变（除非它是一个只读的）。事务必须始终保持系统处于一致的状态，不管在任何给定的时间并发事务有多少。也就是说：如果事务是并发多个，系统也必须如同串行事务一样操作。其主要特征是保护性和不变性(Preserving an Invariant)，以转账案例为例，假设有五个账户，每个账户余额是100元，那么五个账户总额是500元，如果在这个5个账户之间同时发生多个转账，无论并发多少个，比如在A与B账户之间转账5元，在C与D账户之间转账10元，在B与E之间转账15元，五个账户总额也应该还是500元，这就是保护性和不变性。

隔离性(Isolated)

隔离状态执行事务，使它们好像是系统在给定时间内执行的唯一操作。如果有两个事务，运行在相同的时间内，执行相同的功能，事务的隔离性将确保每一事务在系统中认为只有该事务在使用系统。这种属性有时称为串行化，为了防止事务操作间的混淆，必须串行化或序列化请求，使得在同一时间仅有一个请求用于同一数据。

持久性(Durable)

在事务完成以后，该事务对数据库所作的更改便持久的保存在数据库之中，并不会被回滚。

隔离性问题：

脏读：脏读指一个事务读取了另外一个事务未提交的数据。

不可重复读：不可重复读指在一个事务内读取表中的某一行数据，多次读取结果不同。

虚读(幻读) : 虚读(幻读)是指在一个事务内读取到了别的事务插入的数据，导致前后读取不一致

3.JDBC操作事务步骤

示例背景：account数据库中 A有1000元，B有1000元

事务：A向B转账100元

public class TestDemo1 {
    public static void main(String[] args) throws SQLException {
        //这里继续使用前文讲解过的JDBC工具类建立数据库连接和释放资源
        Connection connection = JDBCUtils.getConnection();
        //关闭数据库的事务自动提交，即，开启事务控制；
        connection.setAutoCommit(false);  
        //建立sql语句
        String sql1 = "update account set balance = balance - 100 where name='A'";
        String sql2 = "update account set balance = balance + 100 where name='B'";
        //执行sql语句
        Statement statement = connection.createStatement();    
        statement.executeUpdate(sql1);
        statement.executeUpdate(sql2);
        //事务回滚
        connection.rollback();
        //事务提交
        connection.commit();
        //释放资源
        JDBCUtils.closeAll(null,statement,connection);
    }
}

十、数据库连接池

1.数据库连接池的基本概念

数据库连接是一种关键的有限的昂贵的资源，这一点在多用户的网页应用程序中体现的尤为突出。对数据库连接的管理能显著影响到整个应用程序的伸缩性和健壮性，影响到程序的性能指标.数据库连接池正式针对这个问题提出来的。数据库连接池负责分配,管理和释放数据库连接,它允许应用程序重复使用一个现有的数据库连接,而不是重新建立一个。

数据库连接池在初始化时将创建一定数量的数据库连接放到连接池中，这些数据库连接的数量是由最小数据库连接数来设定的。无论这些数据库连接是否被使用,连接池都将一直保证至少拥有这么多的连接数量。连接池的最大数据库连接数量限定了这个连接池能占有的最大连接数，当应用程序向连接池请求的连接数超过最大连接数量时，这些请求将被加入到等待队列中。

数据库连接池的最小连接数和最大连接数的设置要考虑到以下几个因素:

最小连接数:是连接池一直保持的数据库连接,所以如果应用程序对数据库连接的使用量不大，将会有大量的数据库连接资源被浪费。

最大连接数:是连接池能申请的最大连接数，如果数据库连接请求超过次数，后面的数据库连接请求将被加入到等待队列中，这会影响以后的数据库操作。

如果最小连接数与最大连接数相差很大：那么最先连接请求将会获利，之后超过最小连接数量的连接请求等价于建立一个新的数据库连接。不过，这些大于最小连接数的数据库连接在使用完不会马上被释放，他将被放到连接池中等待重复使用或是空间超时后被释放。

编写连接池需实现java.sql.DataSource接口。

2.开源数据库连接池

现在很多WEB服务器(Weblogic, WebSphere, Tomcat)都提供了DataSoruce的实现，即连接池的实现。通常我们把DataSource的实现，按其英文含义称之为数据源，数据源中都包含了数据库连接池的实现。

也有一些开源组织提供了数据源的独立实现如：

DBCP 数据库连接池

C3P0 数据库连接池

在使用了数据库连接池之后，在项目的实际开发中就不需要编写连接数据库的代码了，直接从数据源获得数据库的连接。

3.DBCP数据源

DBCP 是 Apache 软件基金组织下的开源连接池实现，要使用DBCP数据源，需要应用程序应在系统中增加如下两个 jar 文件：

commons-dbcp-1.4.jar：连接池的实现

commons-pool-1.6.jar：连接池实现的依赖库

Tomcat 的连接池正是采用该连接池来实现的。该数据库连接池既可以与应用服务器整合使用，也可由应用程序独立使用。

配置文件dbcpconfig.properties:

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy?
useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=123456
#<!-- 初始化连接 -->
initialSize=10
#最大连接数量
maxActive=50
#<!-- 最大空闲连接 -->
maxIdle=20
#<!-- 最小空闲连接 -->
minIdle=5
#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000
#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]
#注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=UTF8
#指定由连接池所创建的连接的自动提交（auto-commit）状态。
defaultAutoCommit=true
#driver default 指定由连接池所创建的连接的只读（read-only）状态。
#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：
Informix）defaultReadOnly=
#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED,
REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_UNCOMMITTED

编写工具类进行使用：

public class JdbcUtils_DBCP {
  static{
    try{
        InputStream in = JdbcUtils_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
        Properties properties = new Properties();
        properties.load(in);
        // 创建数据源：工厂模式——>创建
        dataSource = BasicDataSourceFactory.createDataSource(properties);
   }catch (Exception e) {
      e.printStackTrace;
   }
 }
  //从数据源中获取数据库连接
    public static Connection getConnection() throws SQLException{
    //从数据源中获取数据库连接
    return dataSource.getConnection();
 }
  //释放资源
  public static void release(Connection conn,Statement st,ResultSet rs){
    if(rs!=null){
      try{
        //关闭存储查询结果的ResultSet对象
        rs.close();
     }catch (Exception e) {
        e.printStackTrace();
     }
      rs = null;
   }
    if(st!=null){
      try{
        //关闭负责执行SQL命令的Statement对象
        st.close();
     }catch (Exception e) {
        e.printStackTrace();
     }
   }
    if(conn!=null){
      try{
        //将Connection连接对象还给数据库连接池
        conn.close();
     }catch (Exception e) {
        e.printStackTrace();
     }
   }
 }

4.C3P0数据源

C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate，Spring等。C3P0数据源在项目开发中使用得比较多。

需要用到的jar包：c3p0-0.9.5.5.jar，mchange-commons-java-0.2.19.jar

c3p0与dbcp区别:

dbcp没有自动回收空闲连接的功能

c3p0有自动回收空闲连接功能

配置文件c3p0-config.xml：

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
  <!--
  C3P0的缺省(默认)配置，如果在代码中“ComboPooledDataSource ds = new ComboPooledDataSource();”这样写就表示使用的是C3P0的缺省(默认)配置信息来创建数据源
  -->
  <default-config>
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
    <property name="user">root</property>
    <property name="password">123456</property>
    <property name="acquireIncrement">5</property>
    <property name="initialPoolSize">10</property>
    <property name="minPoolSize">5</property>
    <property name="maxPoolSize">20</property>
  </default-config>
  <!--
  C3P0的命名配置，如果在代码中“ComboPooledDataSource ds = new ComboPooledDataSource("MySQL");”这样写就表示使用的是name是MySQL的配置信息来创建数据源
  -->
   <named-config name="MySQL">
    <property name="driverClass">com.mysql.jdbc.Driver</property>
    <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbc?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true</property>
    <property name="user">root</property>
    <property name="password">123456</property>
    <property name="acquireIncrement">5</property>
    <property name="initialPoolSize">10</property>
    <property name="minPoolSize">5</property>
    <property name="maxPoolSize">20</property>
  </named-config>
</c3p0-config>

编写工具类进行使用：

public class JdbcUtils_C3P0 {
  private static ComboPooledDataSource ds = null;
  //在静态代码块中创建数据库连接池
  static{
    try{
      //通过代码创建C3P0数据库连接池
      /*ds = new ComboPooledDataSource();
      ds.setDriverClass("com.mysql.jdbc.Driver");
      ds.setJdbcUrl("jdbc:mysql://localhost:3306/jdbcstudy");
      ds.setUser("root");
      ds.setPassword("123456");
      ds.setInitialPoolSize(10);
      ds.setMinPoolSize(5);
      ds.setMaxPoolSize(20);*/
      //通过读取C3P0的xml配置文件创建数据源，C3P0的xml配置文件c3p0-config.xml必须放在src目录下
      //ds = new ComboPooledDataSource();//使用C3P0的默认配置来创建数据源
      ds = new ComboPooledDataSource("MySQL");//使用C3P0的命名配置来创建数据源
   }catch (Exception e) {
      throw new ExceptionInInitializerError(e);
   }
 }
  //从数据源中获取数据库连接
    public static Connection getConnection() throws SQLException{
    //从数据源中获取数据库连接
    return ds.getConnection();
 }
  //释放资源
  public static void release(Connection conn,Statement st,ResultSet rs){
    if(rs!=null){
      try{
        //关闭存储查询结果的ResultSet对象
        rs.close();
     }catch (Exception e) {
        e.printStackTrace();
     }
      rs = null;
   }
    if(st!=null){
      try{
        //关闭负责执行SQL命令的Statement对象
        st.close();
     }catch (Exception e) {
        e.printStackTrace();
     }
   }
    if(conn!=null){
      try{
        //将Connection连接对象还给数据库连接池
        conn.close();
     }catch (Exception e) {
        e.printStackTrace();
     }
   }
 }

后记

Java全栈学习路线可参考：【Java全栈学习路线】最全的Java学习路线及知识清单，Java自学方向指引，内含最全Java全栈学习技术清单~

【JavaWeb】之JDBC详细介绍（二）

五、Statement对象说明

1.CRUD操作-CREATE

2.CRUD操作-DELETE

3.CRUD操作-UPDATE

4.CRUD操作-READ

七、SQL注入问题

八、PreparedStatement对象说明

九、JDBC操作事务

1.事务概念

2.事务的ACID 原则

3.JDBC操作事务步骤

十、数据库连接池

1.数据库连接池的基本概念

2.开源数据库连接池

3.DBCP数据源

4.C3P0数据源

后记

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

【JavaWeb】之JDBC详细介绍（二）

五、Statement对象说明

1.CRUD操作-CREATE

2.CRUD操作-DELETE

3.CRUD操作-UPDATE

4.CRUD操作-READ

七、SQL注入问题

八、PreparedStatement对象说明

九、JDBC操作事务

1.事务概念

2.事务的ACID 原则

3.JDBC操作事务步骤

十、数据库连接池

1.数据库连接池的基本概念

2.开源数据库连接池

3.DBCP数据源

4.C3P0数据源

后记

热门文章

最新文章

相关课程

相关电子书

相关实验场景