c3p0-0.9.1.2.jar

mysql-connection-java-5.0.8-bin.jar

commons-beanutils-1.8.0.jar

commons-logging.jar

<?xml version="1.0" encoding="utf-8"?>

<c3p0-config>

<default-config>

<property name="initialPoolSize">5</property>

<property name="maxPoolSize">20</property>

<

<property name="jdbcUrl">jdbc:mysql://localhost:3306/day14</property>

<property name="user">root</property>

<property name="password">123456</property>

</default-config>

<named-config

<property name="initialPoolSize">5</property>

<property name="maxPoolSize">20</property>

<property name="driverClass">com.mysql.jdbc.Driver</property>

<property name="jdbcUrl">jdbc:mysql://localhost:3306/day14</property>

<property name="user">root</property>

<property name="password">123456</property>

</named-config>

</c3p0-config>

package cn.toto.domain;

publicclass User {

privateintid;

private String username;

private String password;

publicint getId() {

returnid;

}

publicvoid setId(int id) {

this.id = id;

}

public String getUsername() {

returnusername;

}

publicvoid setUsername(String username) {

this.username = username;

}

public String getPassword() {

returnpassword;

}

publicvoid setPassword(String password) {

this.password = password;

}

public User() {

super();

}

}

package cn.toto.utils;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import javax.sql.DataSource;

import cn.toto.exception.DaoException;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JdbcUtils {

private static DataSource ds;

static {

//ds = new ComboPooledDataSource();//預設的預設的配置

ds = new ComboPooledDataSource("toto");//配置檔案中設定的內容

}

//獲取與指定資料的連線

public static DataSource getSource(){

return ds;

}

//獲得與指定資料庫的連線

public static Connection getConnection() throws SQLException {

//從連線池返回一個連線

return ds.getConnection();

}

//釋放資源

public static void release(ResultSet rs,Statement stmt,Connection conn) {

if(rs!=null){

try{

rs.close();

}catch(SQLException e){

e.printStackTrace();

}

rs = null;

}

if(stmt!=null){

try{

stmt.close();

}catch(SQLException e){

e.printStackTrace();

}

stmt=null;

}

if(conn!=null){

try{

conn.close();

}catch(SQLException e){

e.printStackTrace();

}

conn = null;

}

}

//寫一個通過的增刪改方法

public static boolean update(String sql,Object[] params) {

Connection conn = null;

PreparedStatement pstmt = null;

ResultSet rs = null;

try {

//獲得連線

conn = getConnection();

//寫SQL

//預編譯sql

pstmt = conn.prepareStatement(sql);

//替換引數

int pos = 1;//設定一個腳標

//for(Object param : params)這樣寫是有錯誤的，會有空指標異常，要寫成如下的方法：

pstmt.setObject(i+1, params[1]);//由於不知道是什麼型別的，故可以用Object

//傳送sql

int num = pstmt.executeUpdate();

//返回結果

if(num>0)

return true;

return false;

} catch (SQLException e) {

throw new DaoException(e);

}finally{

release(rs,pstmt,conn);

}

}

//實現一個通用的查詢方法

public static Object query(String sql,Object[] params,ResultSetHandler handler){

Connection conn = null;

PreparedStatement pstmt = null;

ResultSet rs = null;

try{

conn = getConnection();

//寫sql

//預編譯sql

pstmt = conn.prepareStatement(sql);

//替換引數

for(int i=0;params!=null&&i<params.length;i++)

pstmt.setObject(i+1, params[1]);//由於不知道是什麼型別的，故可以用Object

//傳送sql

rs = pstmt.executeQuery();

//處理結果集

/*我們在方法中需要一種功能讓呼叫者裡呼叫

* 在方法的內部都有一個模組不會寫，有變化,需要留給呼叫者來處理*/

//這時我們需要用一種設計模式策略模式 TreeSet

//TreeSet實現排序，只是實現了部分功能（二叉樹，還有沒實現的）

//(元素的比較) 讓我們傳入比較器來實現

//讓我們傳入比較器實現Comparator的compare方法

/*元素的自然順序實現Comparable介面的compareTo方法*/

//向呼叫者要一個結果集處理器

Object result = handler.handle(rs);//呼叫結果處理器的handle方法，它返回的結果就是我們想要的。將結果集變成了一個物件

return result;

}catch(SQLException e){

throw new DaoException(e);

}finally {

release(rs,pstmt,conn);

}

}

}

//寫一個通過的增刪改方法

public static boolean update(String sql,Object[] params) {

Connection conn = null;

PreparedStatement pstmt = null;

ResultSet rs = null;

try {

//獲得連線

conn = getConnection();

//寫SQL

//預編譯sql

pstmt = conn.prepareStatement(sql);

//替換引數

int pos = 1;//設定一個腳標

for(Object param : params)

pstmt.setObject(pos, param);//由於不知道是什麼型別的，故可以用Object

//傳送sql

int num = pstmt.executeUpdate();

//返回結果

if(num>0)

return true;

return false;

} catch (SQLException e) {

throw new DaoException(e);

}finally{

release(rs,pstmt,conn);

}

}

}

package cn.toto.dao;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import cn.toto.domain.User;

import cn.toto.exception.DaoException;

import cn.toto.utils.BeanHandler;

import cn.toto.utils.BeanListHandler;

import cn.toto.utils.JdbcUtils;

import cn.toto.utils.ResultSetHandler;

publicclass UserDao {

public List<User> getAll() {

//寫sql

String sql = "select * from users";

//封裝引數

//實現結果集處理器也可以用預設的實現類

List list = (List) JdbcUtils.query(sql, null, new BeanListHandler(User.class));

return list;

}

public User find(int id){

String sql = "select * from users where id = ?";

//呼叫方法

User user = (User) JdbcUtils.query(sql, new Object[]{id}, new BeanHandler(User.class));

return user;

}

publicboolean insert(User user) {

/*//寫Sql

String sql = "insert into users(username,password) values(?,?)";

//封裝引數

Object[] params = new Object[2];

params[0] = user.getUsername();

params[1] = user.getPassword();

//呼叫新方法

boolean b = JdbcUtils.update(sql, params);

return b;*/

String sql = "insert into users(username,password) values(?,?)";

boolean b = JdbcUtils.update(sql, new Object[]{user.getUsername(),user.getPassword()});

相關推薦