【无标题】动手实践：利用DBUtils实现增删改查

• 搭建开发环境在数据库建表，插入数据
  
• 创建JavaBean
  1. package cn.itcast.jdbc.javabean;
  3. public class User {
  4.         private int id;
  5.         private String name;
  6.         private String password;
  7.         public int getId() {
  8.             return id;
  9.         }
  10.         public void setId(int id) {
  11.             this.id = id;
  12.         }
  13.         public String getName() {
  15.             return name;
  16.         }
  17.         public void setName(String name) {
  19.             this.name = name;
  20.         }
  21.         public String getPassword() {
  23.             return password;
  24.         }
  25.         public void setPassword(String password) {
  27.             this.password = password;
  28.         }
  30. }

  复制代码
  3.创建C3P0Utils工具类
  
  1. package cn.itcast.jdbc.utils;
  2. import javax.sql.DataSource;
  3. import com.mchange.v2.c3p0.ComboPooledDataSource;
  4. public class C3p0Utils {
  5.     private static DataSource ds = null;
  6.     static {
  7.         ComboPooledDataSource  cpds = new ComboPooledDataSource();
  8.         try{
  9.             cpds.setDriverClass("com.mysql.cj.jdbc.Driver");
  10.             cpds.setJdbcUrl("jdbc:mysql://localhost:3306/jdbc?serverTimezone=GMT%2B8");
  11.             cpds.setUser("root");
  12.             cpds.setPassword("123456");
  13.             cpds.setInitialPoolSize(5);
  14.             cpds.setMaxPoolSize(15);
  15.             ds = cpds;
  16.         }catch (Exception e){
  17.             throw new ExceptionInInitializerError(e);
  18.         }
  19.     }
  20.     public static DataSource getDataSource(){
  21.         return ds;
  22.     }
  24. }

  复制代码
  4.创建InsertDao类，完成插入操作
  
  1. package cn.itcast.jdbc.dao;
  2. import java.sql.SQLException;
  3. import org.apache.commons.dbutils.QueryRunner;
  4. import cn.itcast.jdbc.javabean.User;
  5. import cn.itcast.jdbc.utils.C3p0Utils;
  6. public class InsertDao {
  7.     public static  void main(String[] args)throws SQLException{
  8.             QueryRunner runner = new QueryRunner(C3p0Utils.getDataSource());
  9.             String sql = "insert into user (id,name,password) values('4','hello1',123456)";
  10.             int num = runner.update(sql);
  11.             if(num>0){
  12.                 System.out.println("添加成功！");
  13.             }else{
  14.                 System.out.println("添加失败！");
  15.             }
  16.     }
  17. }

  复制代码
  5.创建UpdateDao类，完成修改操作
  
  1. package cn.itcast.jdbc.dao;
  2. import cn.itcast.jdbc.javabean.User;
  3. import cn.itcast.jdbc.utils.C3p0Utils;
  4. import java.sql.SQLException;
  5. import org.apache.commons.dbutils.QueryRunner;
  7. public class UpdateDao {
  8.     public static void main(String[] args) throws SQLException {
  9.         QueryRunner runner = new QueryRunner(C3p0Utils.getDataSource());
  11.         // 修改后的 SQL 语句
  12.         String sql = "update user set name='hello2', password='111111' where id=4";
  14.         // 打印执行的 SQL 语句，确认是否有误
  15.         System.out.println("Executing SQL: " + sql);
  17.         // 执行更新操作
  18.         int num = runner.update(sql);
  20.         // 打印影响的行数
  21.         System.out.println("Affected rows: " + num);
  23.         if (num > 0) {
  24.             System.out.println("修改成功！");
  25.         } else {
  26.             System.out.println("修改失败！");
  27.         }
  28.     }
  29. }

  复制代码
  6.创建DeleteDao类，完成删除操作
  
  1. package cn.itcast.jdbc.dao;
  2. import cn.itcast.jdbc.utils.C3p0Utils;
  3. import java.sql.SQLException;
  4. import org.apache.commons.dbutils.QueryRunner;
  5. public class DeleteDao {
  6.     public static  void main(String[] args)throws SQLException{
  7.         QueryRunner runner = new QueryRunner(C3p0Utils.getDataSource());
  8.         String sql = "delete from user where name='hello2'";
  9.         int num = runner.update(sql);
  10.         if(num>0){
  11.             System.out.println("删除成功！");
  12.         }else{
  13.             System.out.println("删除失败！");
  14.         }
  15.     }
  16. }

  复制代码
  7.创建QueryDao类，完成查询操作
  
  1. package cn.itcast.jdbc.dao;
  2. import java.sql.SQLException;
  3. import org.apache.commons.dbutils.QueryRunner;
  4. import cn.itcast.jdbc.javabean.User;
  5. import cn.itcast.jdbc.utils.C3p0Utils;
  6. import org.apache.commons.dbutils.handlers.BeanHandler;
  7. public class QueryDao {
  8.     public static  void main(String[] args)throws SQLException {
  9.         QueryRunner runner = new QueryRunner(C3p0Utils.getDataSource());
  10.         String sql = "select * from user where id=2";
  11.         User user= (User)runner.query(sql,
  12.                 new BeanHandler(User.class));
  13.             System.out.println(user.getId() + "," + user.getName() + ","
  14.                     + user.getPassword());
  15.         }
  17. }

  复制代码
  1. package cn.itcast.jdbc.dao;
  2. import java.sql.SQLException;
  3. import org.apache.commons.dbutils.QueryRunner;
  4. import cn.itcast.jdbc.javabean.User;
  5. import cn.itcast.jdbc.utils.C3p0Utils;
  6. import org.apache.commons.dbutils.QueryRunner;
  7. import org.apache.commons.dbutils.handlers.BeanListHandler;
  8. import java.util.List;
  9. public class QueryDao {
  10.     public static  void main(String[] args)throws SQLException {
  11.         QueryRunner runner = new QueryRunner(C3p0Utils.getDataSource());
  12.         String sql = "select * from user ";
  13.         List<User> list = runner.query(sql, new BeanListHandler<>(User.class));
  15.         for(User user : list) {
  16.             System.out.println(user.getId() + "," + user.getName() + ","
  17.                     + user.getPassword());
  18.         }
  19.     }
  20. }

  复制代码
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。