自各儿写的一个数据库模板类，可以直接操作封装好的数据对象类
自己写的一个数据库模板类，可以直接操作封装好的数据对象类
package com.drug.db;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Iterator;
/**
* 自己写的一个数据库工具类，希望可以封装所有的数据库操作
* 直接对封装好的数据库对象javaBean进行操作
*
* 数据库中表中的字段名必须首字母大写
* 封装好的数据对象类javaBean中的变量必须和数据库表中的字段相对应，（首字母不用大写）
*
* 这样以后修改数据库，只需要对应的修改一下数据对象类javaBean就行了，呵呵
*
* 本人java还在自学中，望大家多多指正
*/
public class DBUtil {
/**
* 方 法 名： getTableRowCount
* 功能描述： 获取表的行数
* 输入参数: tableName:表名
* 返 回 值： int
* 编 码 人: zmj
* 编码时间: 2010-2-8 上午11:10:26
*/
public int getTableRowCount(String tableName) {
Connection con = null;
PreparedStatement pst = null;
ResultSet rs = null;
int rowCount = -1;
try {
String sql = "select * from " + tableName;
con = getCon();
pst = con.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
rs = pst.executeQuery();
rs.last();
rowCount = rs.getRow();
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} finally {
close(con, pst, rs);
}
return rowCount;
}
/**
* 方 法 名：hasElem
* 功能描述：判断表中是否含有该元素
* 输入参数: tableName：表名，keyName：查询的键值，key用来查询的键
* 返 回 值： boolean
* 编 码 人: zmj
* 编码时间: 2010-2-20 上午10:26:33
*/
public boolean hasElem(String tableName, String keyName, Object key) {
Connection con = null;
PreparedStatement pst = null;
ResultSet rs = null;
String sql = "select * from " + tableName + " where "
+ firstUpper(keyName) + "=?";
try {
con = getCon();
pst = con.prepareStatement(sql);
setObject(pst, 1, key);
rs = pst.executeQuery();
if (rs.next()) {
return true;
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
close(con, pst, rs);
}
return false;
}
/**
* 方 法 名：getTableElem
* 功能描述： 获取数据库中一个表中的全部数据
* 输入参数:tableName：表名，beanName：用来封闭的javaBean
* 返 回 值： ArrayList<Object>
* 编 码 人: zmj
* 编码时间: 2010-2-20 上午08:16:52
*/
public ArrayList<Object> getTableElem(String tableName, String beanName) {
return getElemList(tableName, beanName, 1, -1);
}
/***
* 方 法 名：getTable
* 功能描述：获取数据库中一个表中的数据
* 输入参数:tableName:表名，beanName：用来封装的javaBean，offset：偏移量，count：取出的记录条数，为-1时表示全部
* 返 回值：ArrayList<Object>
* 编 码 人: zmj
* 编码时间: 2010-2-8
* **/
public ArrayList<Object> getElemList(String tableName, String beanName,
int offset, int count) {
Connection con = null;
PreparedStatement pst = null;
ResultSet rs = null;
ArrayList<Object> rs_list = new ArrayList<Object>();
try {
String sql = "select * from " + tableName;
con = getCon();
pst = con.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
rs = pst.executeQuery();
String[] paramName = tableColName(rs);
Class<?> beanClass = Class.forName(beanName);
if (offset > 1)
rs.absolute(offset - 1);
else if (offset < 0 && offset != -1)
return rs_list;
while (rs.next() && (count == -1 || count-- > 0)) {
Object bean = beanClass.newInstance();
saveBean(bean, rs, paramName);
rs_list.add(bean);
}
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InstantiationException e) {
e.printStackTrace();
} finally {
close(con, pst, rs);
}
return rs_list;
}
/**
* 方 法 名：fuzzySearch
* 功能描述： 进行模糊查询
* 输入参数: tableName：表名，beanName：用来封装的javaBean，
keyName：查询的键值，key用来查询的键，offset：偏移量，count：返回的最大个数，-1表示全部
* 返 回 值： ArrayList<Object>
* 编 码 人: zmj
* 编码时间: 2010-2-8 下午01:44:23
*/
public ArrayList<Object> fuzzySearch(String tableName, String beanName,
String fuzzyKeyName, String fuzzyKey, Object[][] key, int offset,
int count) {
Connection con = null;
PreparedStatement pst = null;
ResultSet rs = null;
ArrayList<Object> rs_list = new ArrayList<Object>();
try {
String sql = "select * from " + tableName + " where "
+ firstUpper(fuzzyKeyName) + " like ?";
for (int i = 0; i < key.length; i++) {
if (key[i].length == 2) {
sql += " and " + firstUpper((String) key[i][0]) + "=?";
}
}
con = getCon();
pst = con.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
pst.setObject(1, "%" + fuzzyKey + "%");
for (int i = 0; i < key.length; i++) {
if (key[i].length == 2) {
this.setObject(pst, i + 2, key[i][1]);
}
}
rs = pst.executeQuery();
String[] paramName = tableColName(rs);
Class<?> beanClass = Class.forName(beanName);
if (offset > 1)
rs.absolute(offset - 1);
else if (offset < 0 && offset != -1)
return rs_list;
while (rs.next() && (count == -1 || count-- > 0)) {
Object bean = beanClass.newInstance();
saveBean(bean, rs, paramName);
rs_list.add(bean);
}
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InstantiationException e) {
e.printStackTrace();
} finally {
close(con, pst, rs);
}
return rs_list;
}
/***
* 方 法 名：getElem
* 功能描述：获取数据库中一个表中的一条记录
* 输入参数:tableName:表名，beanName：javaBean的名字
* 返 回 值：Object
* 编 码 人: zmj
* 编码时间: 2010-2-8
* @throws SQLException
* **/
public Object getElem(String tableName, String keyName, Object key,
String beanName) {
Connection con = null;
PreparedStatement pst = null;
ResultSet rs = null;
String sql = "select * from " + tableName + " where "
+ firstUpper(keyName) + "=?";
String[] paramName = null;
try {
con = getCon();
pst = con.prepareStatement(sql);
setObject(pst, 1, key);
rs = pst.executeQuery();
paramName = tableColName(rs);
Class<?> beanClass;
beanClass = Class.forName(beanName);
Object bean = null;
bean = beanClass.newInstance();
if (rs.next()) {
saveBean(bean, rs, paramName);
}
return bean;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} finally {
close(con, pst, rs);
}
return null;
}
/***
* 方 法 名：insert
* 功能描述：将JavaBean添加到数据库表table中
* 输入参数: tableName:表名，bean：javaBean
* 返 回 值：int
* 编 码 人: zmj
* 编码时间: 2010-2-8
* **/
public int insert(String tableName, Object bean) {
Connection con = null;
PreparedStatement pst = null;
StringBuilder sql = new StringBuilder("insert into " + tableName + "(");
try {
Object[][] beanObj = bean2Array(bean);
int n = beanObj.length;
if (n < 1) {
return 0;
}
for (int i = 0; i < n; i++) {
if (i != 0)
sql.append(",");
sql.append(beanObj[i][0]);
}
sql.append(") values(");
for (int i = 0; i < n; i++) {
if (i != 0)
sql.append(",");
sql.append("?");
}
sql.append(")");
con = getCon();
pst = con.prepareStatement(sql.toString());
for (int i = 0; i < n; i++) {
setObject(pst, i + 1, beanObj[i][1]);
}
return pst.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} finally {
close(con, pst);
}
return 0;
}
/**
* 方 法 名：updateElem
* 功能描述： 更新表中的一个元素
* 输入参数: tableName，keyName，key，bean
* 返 回 值： int
* 编 码 人: zmj
* 编码时间: 2010-2-8 上午11:30:18
*/
public int updateElem(String tableName, String keyName, Object key,
Object bean) {
Connection con = null;
PreparedStatement pst = null;
StringBuilder sql = new StringBuilder("update " + tableName + " set ");
try {
Object[][] beanObj = bean2Array(bean);
int n = beanObj.length;
if (n < 1) {
return 0;
}
for (int i = 0; i < n; i++) {
if (i != 0)
sql.append(",");
sql.append(beanObj[i][0] + "=?");
}
sql.append(" where " + firstUpper(keyName) + "=?");
con = getCon();
pst = con.prepareStatement(sql.toString());
int i = 0;
for (; i < n; i++) {
setObject(pst, i + 1, beanObj[i][1]);
}
setObject(pst, i + 1, key);
return pst.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} finally {
close(con, pst);
}
return 0;
}
/**
* 方 法 名： deleteElem
* 功能描述： 删除表中的一条记录
* 输入参数: tableName：表名， keyName：键名 key：键值
* 返 回 值： int
* 编 码 人: zmj
* 编码时间: 2010-2-8 下午01:47:08
*/
public int deleteElem(String tableName, String keyName, Object key) {
Connection con = null;
PreparedStatement pst = null;
StringBuilder sql = new StringBuilder("delete from " + tableName);
try {
sql.append(" where " + firstUpper(keyName) + "=?");
con = getCon();
pst = con.prepareStatement(sql.toString());
setObject(pst, 1, key);
int count = pst.executeUpdate();
return count;
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} finally {
close(con, pst);
}
return 0;
}
/**
* 方 法 名：setObject
* 功能描述：私有方法，设置preparedStatement的setXXX项
* 输入参数: pst：PreparedStatement对象，i：列的位置，obj：要插入的对象
* 返 回 值： void
* 编 码 人: zmj
* 编码时间: 2010-2-8 上午11:13:02
*/
private void setObject(PreparedStatement pst, int i, Object obj)
throws SQLException {
if (obj == null) {
pst.setString(i, null);
} else if (obj.getClass() == java.util.Date.class) {
long l = ((java.util.Date) obj).getTime();
java.sql.Timestamp t = new java.sql.Timestamp(l);
pst.setTimestamp(i, t);
} else {
pst.setObject(i, obj);
}
}
// 私有方法，把javabean存放到Object二维数组中
private Object[][] bean2Array(Object bean) {
Class<? extends Object> beanClass = bean.getClass();
Field[] field = beanClass.getDeclaredFields();
Method[] method = beanClass.getDeclaredMethods();
ArrayList<Object> list = new ArrayList<Object>();
for (int i = 0; i < field.length; i++) {
for (int j = 0; j < method.length; j++) {
String methodName = method[j].getName();
if (isGetMethod(methodName)
&& methodName.contains(firstUpper(field[i].getName()))) {
Object o = null;
try {
o = method[j].invoke(bean);
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
if (o != null) {
list.add(field[i].getName());
list.add(o);
}
}
}
}
int m = list.size();
if (m < 1 || m % 2 != 0) {
return new Object[0][0];
}
Object[][] bean_obj = new Object[m / 2][2];
Iterator<Object> iter = list.iterator();
int i = 0;
while (iter.hasNext()) {
bean_obj[i][0] = iter.next();
bean_obj[i][1] = iter.next();
i++;
}
return bean_obj;
}
// 私有方法，返回表中列名
private String[] tableColName(ResultSet rs) throws SQLException {
ResultSetMetaData rsmd = rs.getMetaData();
int n = rsmd.getColumnCount();
String[] name = new String[n];
for (int i = 0; i < n; i++) {
name[i] = rsmd.getColumnName(i + 1);
}
return name;
}
// 私有方法，保存ResultSet一行记录到一个javaBean中
private void saveBean(Object bean, ResultSet rs, String[] paramName)
throws SQLException {
Method[] method = bean.getClass().getDeclaredMethods();
for (int i = 0; i < paramName.length; i++) {
for (int j = 0; j < method.length; j++) {
String methodName = method[j].getName();
if (methodName.endsWith(paramName[i])
&& isSetMethod(methodName)) {
Object param = rs.getObject(paramName[i]);
if (param != null) {
// 如果为Timestamp类，则转换为Date类
if (param.getClass() == java.sql.Timestamp.class) {
long l = ((java.sql.Timestamp) param).getTime();
param = new java.util.Date(l);
}
try {
method[j].invoke(bean, param);
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
}
}
}
}
// 私有方法，判断是否为getter方法
private boolean isGetMethod(String methodName) {
if (methodName == null)
return false;
return methodName.startsWith("is") || methodName.startsWith("get");
}
// 私有方法，判断是否为setter方法
private boolean isSetMethod(String methodName) {
if (methodName == null)
return false;
return methodName.startsWith("set");
}
// 私有方法，将首字母大写
private String firstUpper(String s) {
return s.substring(0, 1).toUpperCase() + s.substring(1);
}
// 私有方法，获取数据库连接
private Connection getCon() throws ClassNotFoundException, SQLException {
DB.getInstance();
return DB.getConnection();
}
// 私有方法，关闭数据库操作1,用于查询数据库操作
private void close(Connection con, PreparedStatement pst, ResultSet rs) {
try {
if (rs != null)
rs.close();
if (pst != null)
pst.close();
if (con != null)
DB.release(con);
} catch (SQLException e) {
e.printStackTrace();
}
}
// 私有方法，关闭数据库操作2,用于更新数据库操作
//我用的数据库为access，不知道为什么，数据库Connection不关闭，数据库不更新，求解！！
private void close(Connection con, PreparedStatement pst) {
try {
if (pst != null)
pst.close();
if (con != null) {
con.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/*
* 自己写的一个很简单的数据库连接池
*/
package com.drug.db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Stack;
public class DB {
private static DB DB_INSTANCE = null;
private static int MAX = 40;
private static Stack<Connection> CON_POOL = new Stack<Connection>();
// 数据库配置
private static String className = "sun.jdbc.odbc.JdbcOdbcDriver";
private static String url = "jdbc:odbc:test";
// 同步对象
private final static byte[] lock = new byte[0];
private DB() throws ClassNotFoundException {
Class.forName(className);
}
// 返回单一实例
public static DB getInstance() throws ClassNotFoundException {
if (DB_INSTANCE == null) {
DB_INSTANCE = new DB();
}
return DB_INSTANCE;
}
// 获取连接
public static Connection getConnection() throws SQLException {
synchronized (lock) {
if (CON_POOL.isEmpty()) {
return DriverManager.getConnection(url);
}
return CON_POOL.pop();
}
}
// 释放连接
public static void release(Connection con) throws SQLException {
synchronized (lock) {
if (con == null || con.isClosed()) {
return;
} else if (CON_POOL.size() < MAX + 1) {
CON_POOL.push(con);
} else {
con.close();
}
}
}
}
1 楼
myclover
2010-03-20
不错，很厉害啊！