DBUtils基本使用

导入相关的jar包

package dbutil.zr.com;

import java.sql.Connection;
import java.sql.DriverManager;

import javax.sql.DataSource;


public class Conenction {
    
//    public static void main(String[] args) {
//        System.out.println(Conenction.getConnection());
//    }

    private static String driverClassName="com.mysql.jdbc.Driver";
    
    private static String url = "jdbc:mysql://localhost:3306/test";
    
    private static String user = "root";
    
    private static String password="";
    
    

    /**
     * 获取connection
     * @return
     */
    public static Connection getConnection(){
        Connection conenction = null;
        try {
            Class.forName(driverClassName);
            conenction = DriverManager.getConnection(url, user, password);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conenction;
    }
    
}

package dbutil.zr.com.pojo;

public class Student {
    
    private String stu_id;
    
    private String stu_name;
    
    private String class_id;

    public String getStu_id() {
        return stu_id;
    }

    public void setStu_id(String stu_id) {
        this.stu_id = stu_id;
    }

    public String getStu_name() {
        return stu_name;
    }

    public void setStu_name(String stu_name) {
        this.stu_name = stu_name;
    }

    public String getClass_id() {
        return class_id;
    }

    public void setClass_id(String class_id) {
        this.class_id = class_id;
    }

    public Student() {
        super();
    }

    public Student(String stu_id, String stu_name, String class_id) {
        super();
        this.stu_id = stu_id;
        this.stu_name = stu_name;
        this.class_id = class_id;
    }

    @Override
    public String toString() {
        return "Student [stu_id=" + stu_id + ", stu_name=" + stu_name
                + ", class_id=" + class_id + "]";
    }

    

    
    
    
    
}

package dbutil.zr.com.util;

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

import javax.enterprise.inject.New;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;

import dbutil.zr.com.Conenction;
import dbutil.zr.com.pojo.Student;

public class TestClass<T> {

    public static void main(String[] args) {
//        // 添加数据
//        String sql1 = "insert into student (stu_id,stu_name,class_id) values(?,?,?)";
//        TestClass.operationData(sql1,2,"zlf",102);
//        
//        // 更新数据
//        String sql2 = "update student set class_id=? where stu_id=?";
//        TestClass.operationData(sql2, 103,2);
//        
//        // 删除数据
//        String sql3 = "delete from student where stu_id=?";
//        TestClass.operationData(sql3, 2);
        
        // 查询数据
        String sql = "select * from student";
        Student student = new Student();
        List<Student> students = TestClass.select(sql,student);
        for (Student student2 : students) {
            System.out.println(student2);
        }
    }
    
    /**
     * 添加数据
     * @param sql
     */
    public static void operationData(String sql,Object...params){
        // 获取连接
        Connection connection = Conenction.getConnection();
        // 创建SQL执行工具
        QueryRunner queryRunner = new QueryRunner();
        int n = 0;
        try {
            // 执行SQL插入
            n = queryRunner.update(connection, sql, params);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            System.out.println("成功操作"+n+"条数据");
             // 关闭连接
            DbUtils.closeQuietly(connection);
        }
        
                 
    }
    
    /**
     * 查询数据
     */
    public static <T> List<T> select(String sql,T t){
        // 获取连接
        Connection connection = Conenction.getConnection();
        // 创建SQL执行工具
        QueryRunner queryRunner = new QueryRunner();
        List<T> list = null;
        try {
            list =(List<T>) queryRunner.query(connection, sql, new BeanListHandler(t.getClass()));
            
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            // 关闭连接
            DbUtils.closeQuietly(connection);
        }
        return list;
    }
    

}