package dbUtils;import java.sql.Connection;import java.sql.SQLException;import java.util.List;import org.apache.commons.dbutils.QueryRunner;import org.apache.commons.dbutils.ResultSetHandler;import org.apache.commons.dbutils.handlers.ArrayListHandler;import org.apache.commons.dbutils.handlers.BeanListHandler;import cn.utils.C3p0Utils;public class DbUtlisTest { //新增public static void test1 () throws SQLException{QueryRunner run = new QueryRunner(C3p0Utils.getDatatSource());run.update("insert into stu(id,name,sex) values(?,?,?)","10001","jack","1");}//事物 开启事物必须传递Connectionpublic static void test2() throws SQLException{Connection con = C3p0Utils.getConnection();try {con.setAutoCommit(false);QueryRunner run = new QueryRunner();run.update(con,"insert into stu(id,name,sex) values(?,?,?)",new Object[]{10004,"mary","0"});run.update(con,"insert into stu(id,name,sex) values(?,?,?)",10005,"mark","1");con.commit();System.err.println("jieshu");}catch (Exception e) {System.err.println(e.getMessage());con.rollback();} finally {con.close();}}//查询封装public static void test4()throws SQLException{ Connection con = C3p0Utils.getConnection(); QueryRunner run = new QueryRunner(); Listlist = run.query(con, "select * from stu",new BeanListHandler<>(Stu.class)); for (int i = 0; i < list.size(); i++) { Stu stu = list.get(i); System.err.println(stu.toString()); }}//修改 public static void test5()throws SQLException{ QueryRunner run = new QueryRunner(C3p0Utils.getDatatSource()); int n = run.update("update stu set name =? where id = ?","jack333",1009); System.err.println(n);}//删除public static void test6()throws SQLException{// QueryRunner run = new QueryRunner();// int n = run.update(C3p0Utils.getConnection(),"delete from stu where id =?", 10003);// 或者下面的 QueryRunner run = new QueryRunner(C3p0Utils.getDatatSource()); int n = run.update(C3p0Utils.getConnection(),"delete from stu where id =?", 10002); System.err.println(n);//0失败 1成功}public static void main(String[] args) throws SQLException { test5();}}