用数据库连接池c3p0来连接数据库,用queryrunner来操作

              一般在进行简单的java程序时，我们都会选择jdbc来连接数据库。但是你会发现jdbc操作数据库时的代码非常繁琐。那么有没有别的办法来替代jdbc来进行数据库的操作，且代码相当简单一点呢。答案是有的。我们要用的是queryrunner来进行操作，你会发现queryrunner将很多的都封装起来了，所以代码会变得更加简单直观。

      我们先来操作数据库。在用数据库连接池时，我们要先导入c3p0-0.9.1.1.jar和mysql-connector-java-5.1.7-bin.jar，对mysql数据库进行操作 。

JDBCUtils：      
 private static ComboPooledDataSource dataSource = new ComboPooledDataSource();

//静态代码块自动装载连接数据库的四个参数

static {
try {
dataSource.setDriverClass("com.mysql.jdbc.Driver");
dataSource.setJdbcUrl(jdbc:mysql:///test);
dataSource.setUser("root");
dataSource.setPassword("root");
dataSource.setMaxPoolSize(10);//设置最大的连接数
dataSource.setMinPoolSize(0);//设置最小的连接数
dataSource.setInitialPoolSize(5);//初始化连接数
dataSource.setAcquireIncrement(5);//连接数的增量
} catch (PropertyVetoException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

//获得连接
4000
public static Connection getConnection() {
try {
return dataSource.getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}

public static ComboPooledDataSource getDataSource() {
return dataSource;
}

  做到上面这几部就可以连接到数据库了。那么接下来就是用queryrunner来进行对数据库的操作。要想使用queryrunner，我们首先的导入commons-dbutils-1.2.jar。

   接下来就是对数据库的操作

   

在dao层先获得连接： 

static QueryRunner queryRunner = new QueryRunner(JDBCUtils.getDataSource());
static Connection conn = JDBCUtils.getConnection();    //获得连接

  

然后进行操作：

得到整个对象:

public static User findById(int id) {
String sql = "select * from user where id=? ";
Object[] params = { id };
try {
return (User) queryRunner.query(conn, sql, params, new BeanHandler(User.class));
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}

得到列表：

public static List<User>  list() {
String sql = "select * from user ";
Object[] params = {  };
try {
return (MailDetails) queryRunner.query(conn, sql, params, new BeanListHandler(User.class));
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}

 更新数据：

public static void update(int id) {
String sql = "update user set name='我就是我，是不一样的烟花' where id=?";
Object[] params = { id };
try {
queryRunner.update(conn, sql, params);
} catch (SQLException e) {
e.printStackTrace();
}
}