数据库操作代码,Java代码库,德仔网

代码语言
代码分类
【Java】数据库操作
作者: / 发布于2011/1/14/ 539
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;

import com.hewei.exception.MyException;

public class DBHelp {
// 注册数据库驱动
private final static String SQL_DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
// 数据库链接地址
private final static String SQL_URL = "jdbc:microsoft:sqlserver://127.0.0.1:7788;databaseName=myWork";
// 数据库用户名
private final static String SQL_NAME = "sa";
// 数据库密码
private final static String SQL_PASSWORD = "";

private Connection conn = null;

private ResultSet rs = null;

private PreparedStatement stmt = null;

// 打开链接
public Connection getConnection() throws MyException {
try {
Class.forName(DBHelp.SQL_DRIVER);
conn = DriverManager.getConnection(DBHelp.SQL_URL, DBHelp.SQL_NAME,
DBHelp.SQL_PASSWORD);
} catch (ClassNotFoundException e) {
throw new MyException("数据库链接异常！");
} catch (SQLException e) {
throw new MyException("数据库链接异常！");
}
return conn;
}

// 关闭资源
public void releaseSource(ResultSet rs, PreparedStatement stmt,
Connection conn) throws MyException {
try {
if (null != rs) {

rs.close();

}
if (null != stmt) {
stmt.close();
}
if (!conn.isClosed() && null != conn) {
conn.close();
}

} catch (Exception ex) {

throw new MyException("数据库关闭异常！");
}
}

// 通用增加删除修改单条记录
public boolean extceNoQuery(String sql, Object[] obj) throws MyException {
try {
conn = this.getConnection();
conn.setAutoCommit(false);
stmt = conn.prepareStatement(sql);
if (null != obj) {
for (int i = 0; i < obj.length; i++) {
stmt.setObject(i + 1, obj[i]);
}
int rowCount = stmt.executeUpdate();
if (rowCount == 1) {
conn.commit();
} else {
conn.rollback();
}
return rowCount == 1;
} else {
return false;
}
} catch (Exception ex) {

throw new MyException("数据库异常！");
} finally {
releaseSource(rs, stmt, conn);
}

}

// 查询方法(返回一条记录)
public Object queryObject(String sql, Object[] obj, Class clazz)
throws MyException {
try {
Object object = null;
String colName = "";
String methodName = "";
conn = this.getConnection();
stmt = conn.prepareStatement(sql);

for (int i = 0; null != obj && i < obj.length; i++) {
stmt.setObject(i + 1, obj[i]);
}
rs = stmt.executeQuery();
ResultSetMetaData resultSetMetaData = rs.getMetaData();

int colNumber = resultSetMetaData.getColumnCount();
String[] cols = new String[colNumber];// 拿到要查询的列
for (int k = 1; k <= colNumber; k++) {

cols[k - 1] = resultSetMetaData.getColumnName(k);
}
Method[] methods = clazz.getDeclaredMethods();

if (rs.next()) {
object = clazz.newInstance();

for (int n = 0; n < cols.length; n++) {
methodName = cols[n];
colName = "set" + cols[n];
for (Method ms : methods) {

if (ms.getName().equals(colName)) {
ms.invoke(object, rs.getObject(methodName));
}
}
}
}
return object;
} catch (Exception ex) {
ex.printStackTrace();
return null;
} finally {
releaseSource(rs, stmt, conn);
}
}

// 通用数据列表方法(返回多条记录)
public List queryList(String sql, Object[] obj, Class clazz)
throws MyException {

try {
List listObject = new ArrayList();
Object object = null;
String methodName = "";
String colName = "";
conn = this.getConnection();
stmt = conn.prepareStatement(sql);
if(null != obj){
for (int i = 0; i < obj.length; i++) {
// System.out.println("jieguo"+obj[i]);
stmt.setObject(i + 1, obj[i]);
} 
}

rs = stmt.executeQuery();
if (null != rs) {
ResultSetMetaData resultSetMetaData = rs.getMetaData();
int colNumber = resultSetMetaData.getColumnCount();
String[] cols = new String[colNumber];// 拿到要查询的列
for (int k = 1; k <= colNumber; k++) {
cols[k - 1] = resultSetMetaData.getColumnLabel(k);
}
Method[] methods = clazz.getDeclaredMethods();
while (rs.next()) {
object = clazz.newInstance();
for (int m = 0; m < cols.length; m++) {
colName = "set" + cols[m];
// System.out.println("colName=="+colName);
for (Method ms : methods) {
methodName = ms.getName();
// System.out.println("methodName=="+methodName);
if (methodName.equals(colName)) {
// System.out.println(rs.getObject(cols[m]));
ms.invoke(object, rs.getObject(cols[m]));
}
}
}
listObject.add(object);
}
} else {
return null;
}

if (null != listObject && listObject.size() > 0) {
return listObject;
} else {
return null;
}
} catch (Exception ex) {
ex.printStackTrace();
return null;
// throw new MyException("数据库查询列表异常！");
} finally {
releaseSource(rs, stmt, conn);
}

}

/*
* 
* 根据某个属性查询某个单个字段
*/
public Object getBeanProptyByPropty(String sql, Object[] obj) {
try {
conn = this.getConnection();

stmt = conn.prepareStatement(sql);

if (null != obj) {

for (int i = 0; i < obj.length; i++) {

stmt.setObject(i + 1, obj[i]);
}
}

rs = stmt.executeQuery();

if (rs.next()) {

return rs.getObject(1);
}
} catch (Exception ex) {

}
return null;
}
}
</div>
试试其它关键字
　数据库操作　
同语言下
可能有用的
贡献的其它代码Label