JDBC-Web简单运用

package com.crainyday.web;

import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 * JDBC 操作工具类
 * 1. 获取数据库连接
 * 2. 释放数据库连接
 * @author crainyday
 *
 */
public class JDBCUtils {
    // 注意数据源只创建一次即可, 需要在静态代码块里初始化
    private static DataSource ds = null;
    static {
        // 这里的数据源名为：c3p0-config.xml文件中的named-config标签中的 name 属性值。
        ds = new ComboPooledDataSource("web");
    }
    /**
	 * 释放一个 connection 连接
	 * @param connection
	 */
    public static void release(Connection connection) {
        try {
            if(connection != null) {
                connection.close();
            }
        } catch (SQLException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
    }
    /**
	 * 返回数据源的一个 connection 连接对象
	 * @return
	 * @throws SQLException 
	 */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }
}

package com.crainyday.web;

import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.util.List;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
/**
 * 
 * @author crainyday
 * 封装了基本的 CRUD 的方法, 以供子类继承使用
 * 当前 DAO 无事务操作,直接在方法中获取数据库连接
 * 整个 DAO 采用 DBUtils 方案解决
 * @param <T>: 当前 DAO 操作的实体类型
 */

public class DAO<T> {
    // QueryRunner 是线程安全的
    private QueryRunner qr = new QueryRunner();
    private Class<T> clazz;
    /**
	 * DAO 构造函数: 利用反射确定当前 DAO 操作的实体类型 clazz
	 */
    @SuppressWarnings("unchecked")
    public DAO() {
        Type superClass = getClass().getGenericSuperclass();
        if(superClass instanceof ParameterizedType) {
            ParameterizedType parameterizedType = (ParameterizedType) superClass;
            Type [] typeArgs = parameterizedType.getActualTypeArguments();
            if(typeArgs != null && typeArgs.length > 0) {
                if(typeArgs[0] instanceof Class) {
                    clazz = (Class<T>) typeArgs[0];
                }
            }
        }
    }
    /**
	 * 返回某一个字段的值 或 数据表中符合条件的记录数
	 * @param sql
	 * @param args
	 * @return
	 */
    public <E> E getForValue(String sql, Object ...args) {
        Connection connection = null;
        try {
            connection = JDBCUtils.getConnection();
            return (E) qr.query(connection, sql, new ScalarHandler<E>(), args);
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }finally {
            JDBCUtils.release(connection);
        }
        return null;
    }
    
    /**
	 * 返回 T 所对应的 List
	 * @param sql
	 * @param args
	 * @return
	 */
    public List<T> getForList(String sql, Object ...args){
        Connection connection = null;
        try {
            connection = JDBCUtils.getConnection();
            return qr.query(connection, sql, new BeanListHandler<>(clazz), args);
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }finally {
            JDBCUtils.release(connection);
        }
        return null;
    }
    /**
	 * 返回 T 所对应的一个实体类的对象
	 * @param sql
	 * @param args
	 * @return
	 */
    public T get(String sql, Object ...args) {
        Connection connection = null;
        try {
            connection = JDBCUtils.getConnection();
            return qr.query(connection, sql, new BeanHandler<>(clazz), args);
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }finally {
            JDBCUtils.release(connection);
        }
        return null;
    }
    
    /**
	 * 该方法封装了 INSERT DELETE UPDATE 操作.
	 * @param sql  sql 语句
	 * @param args
	 */
    public void update(String sql, Object ... args) {
        Connection connection = null;
        try {
            connection = JDBCUtils.getConnection();
            qr.update(connection, sql, args);
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }finally {
            JDBCUtils.release(connection);
        }
    }
}

package com.crainyday.web;
/**
 * UserBean 操作接口
 * @author crainyday
 *
 */
public interface UserDAO {
    /**
	 * 用户注册
	 * @param user
	 */
    public void register(User user);
    /**
	 * 用户登录
	 * @param username
	 * @param password
	 * @return
	 */
    public User login(String username, String password);
    /**
	 * 返回和 username 相等的记录条数
	 * @param username
	 * @return
	 */
    public long getUsernameCount(String username);
    /**
	 * 返回和 email 相等的记录条数
	 * @param email
	 * @return
	 */
    public long getEmailCount(String email);
}

package com.crainyday.web;

/**
 * User 数据访问对象 JDBC 的实现
 * 操作数据库:用户登陆,用户注册,查询用户
 * @author crainyday
 *
 */

public class UserDAOJDBCImpl extends DAO<User> implements UserDAO {
    @Override
    public void register(User user) {
        String sql = "INSERT INTO user VALUES(?,?,?,?,?,?)";
        update(sql, user.getUserId(),user.getUserName(), user.getPassword(), user.getAge(), user.getAddress(), user.getEmail());
    }
    @Override
    public User login(String username, String password) {
        String sql = "SELECT * FROM user WHERE userName = ?";
        return get(sql, username);
    }
    @Override
    public long getUsernameCount(String username) {
        String sql = "SELECT count(userId) FROM user WHERE userName = ?";
        return getForValue(sql, username);
    }
    @Override
    public long getEmailCount(String email) {
        String sql = "SELECT count(userId) FROM user WHERE email = ?";
        return getForValue(sql, email);
    }
}