登录
首页 >  数据库 >  MySQL

Java编程基础34——JDBC&DBUtil

来源:SegmentFault

时间:2023-02-16 15:38:19 234浏览 收藏

在数据库实战开发的过程中,我们经常会遇到一些这样那样的问题,然后要卡好半天,等问题解决了才发现原来一些细节知识点还是没有掌握好。今天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 每个列数据类型不同
     */
    public static void columnListHandler()throws SQLException{
        QueryRunner qr = new QueryRunner();
        String sql = "SELECT * FROM sort ";        
        //调用方法 query,传递结果集实现类ColumnListHandler
        //实现类构造方法中,使用字符串的列名
        List list = qr.query(con, sql, new ColumnListHandler("sname"));
        for(Object obj : list){
            System.out.println(obj);
        }
    }    
  • 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());
        System.out.println(count);
    }
}
  • 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 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("数据添加失败");
        }
    }

}

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

声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表