Java编程基础34——JDBC&DBUtil

在数据库实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《Java编程基础34——JDBC&DBUtil》，聊聊MySQL、Java，希望可以帮助到正在努力赚钱的你。

1.DButils工具类的介绍个三个核心类

• A: 概述

  • DBUtils是java编程中的数据库操作实用工具，小巧简单实用。
  • DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。
  • DBUtils就是JDBC的简化开发工具包。需要项目导入commons-dbutils-1.6.jar才能够正常使用DBUtils工具。

• B: Dbutils三个核心功能介绍

  • QueryRunner中提供对sql语句操作的API.

    • update(Connection conn, String sql, Object... params) ，用来完成表数据的增加、删除、更新操作
    • query(Connection conn, String sql, ResultSetHandler rsh, Object... params) ，用来完成表数据的查询操作
  • ResultSetHandler接口，用于定义select操作后，怎样封装结果集.
  • DbUtils类，它就是一个工具类,定义了关闭资源与事务处理的方法

2.事务的简单介绍

• A: 事物处理,转账案例
• B: 事务.jpg

3.QueryRunner类的update方法介绍

• A: 方法介绍

  • update(Connection conn, String sql, Object... params) ，用来完成表数据的增加、删除、更新操作
  • 使用QueryRunner类,实现对数据表的insert delete update

  • 调用QueryRunner类的方法 update (Connection con,String sql,Object...param)

    • Object...param 可变参数,Object类型,SQL语句会出现?占位符
    • 数据库连接对象,自定义的工具类传递

4.QueryRunner类实现insert,update,delete

• A: 案例代码

public class QueryRunnerDemo1 {
    private static Connection con = JDBCUtilsConfig.getConnection();
    public static void main(String[] args) throws SQLException{
        arrayHandler();
    }    
    /*
     *  结果集第一种处理方法, ArrayHandler
     *  将结果集的第一行存储到对象数组中  Object[]
     */
    public static void arrayHandler()throws SQLException{
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort";
        //调用方法query执行查询,传递连接对象,SQL语句,结果集处理方式的实现类
        //返回对象数组
        Object[] result = qr.query(con, sql, new ArrayHandler());
        for(Object obj : result){
            System.out.print(obj);
        }
    }    
}

• B: 结果集处理ArrayListHandler

public class QueryRunnerDemo1 {
    private static Connection con = JDBCUtilsConfig.getConnection();
    public static void main(String[] args) throws SQLException{
        columnListHandler();
    }    
    /*
     *  结果集第五种处理方法,ColumnListHandler
     *  结果集,指定列的数据,存储到List集合
     *  List<object> 每个列数据类型不同
     */
    public static void columnListHandler()throws SQLException{
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort ";        
        //调用方法 query,传递结果集实现类ColumnListHandler
        //实现类构造方法中,使用字符串的列名
        List<object> list = qr.query(con, sql, new ColumnListHandler<object>("sname"));
        for(Object obj : list){
            System.out.println(obj);
        }
    }    
</object></object></object>

• F: 结果集处理ScalarHandler

public class QueryRunnerDemo1 {
    private static Connection con = JDBCUtilsConfig.getConnection();
    public static void main(String[] args) throws SQLException{
        scalarHandler();
    }    
    /*
     *  结果集第六种处理方法,ScalarHandler
     *  对于查询后,只有1个结果
     */
    public static void scalarHandler()throws SQLException{
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT COUNT(*) FROM sort";
        //调用方法query,传递结果集处理实现类ScalarHandler
        long count = qr.query(con, sql, new ScalarHandler<long>());
        System.out.println(count);
    }
}</long>

• G: 结果集处理MapHandler

/*
 *  测试写好的工具类,
 *  提供的是一个DataSource接口的数据源
 *  QueryRunner类构造方法,接收DataSource接口的实现类
 *  后面,调用方法update,query,无需传递他们Connection连接对象
 */

import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayListHandler;

import cn.itcast.jdbcutils.JDBCUtils;
public class QueryRunnerDemo{
    public static void main(String[] args) {
        select();
    }
    //定义2个方法,实现数据表的添加,数据表查询
    //QueryRunner类对象,写在类成员位置
    private static QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource()); 

    //数据表查询
    public static void select(){
        String sql = "SELECT * FROM sort";
        try{
        List<object> list = qr.query(sql, new ArrayListHandler());
        for(Object[] objs : list){
            for(Object obj : objs){
                System.out.print(obj+"\t");
            }
            System.out.println();
        }
        }catch(SQLException ex){
            throw new RuntimeException("数据查询失败");
        }
    }

    //数据表添加数据
    public static void insert(){
        String sql = "INSERT INTO sort (sname,sprice,sdesc)VALUES(?,?,?)";
        Object[] params = {"水果",100.12,"刚刚上市的核桃"};
        try{
            int row = qr.update(sql, params);
            System.out.println(row);
        }catch(SQLException ex){
            throw new RuntimeException("数据添加失败");
        }
    }

}</object>

今天带大家了解了MySQL、Java的相关知识，希望对你有所帮助；关于数据库的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~