当前位置：首页 -> AI编程基础 -> JAVA

java操作数据库的工具类 (四)

2014-11-24 11:24:38 · 作者: · 浏览: 19
标签: java 操作 数据库 工具
.class
* @param sqlQry
* 查询SQL(参数用 代替)
* @param params
* 参数List
可以是数组

* @return 指定类型的对象
*/
public T queryFirstOrDefault(Class c, String sqlQry,
List params) {
T t = null;
sqlQry += " limit 1";
List list = executeQuery(c, sqlQry, params);
if (list != null && list.size() > 0) {
t = list.get(0);
}
return t;
}

/**
* {@link com.lingan.common.AbstractDao#queryFirstOrDefault(Class, String, List)
* 查看queryFirstOrDefault}
*/
public T queryFirstOrDefault(Class c, String sqlQry, Object[] params) {
List list = new ArrayList();
if (params != null) {
for (Object o : params) {
list.add(o);
}
}
return queryFirstOrDefault(c, sqlQry, list);
}

/**
* {@link com.lingan.common.AbstractDao#executeUpdate(String,List)
* 查看executeUpdate}
*/
public int executeUpdate(String sqlQry) {

return executeUpdate(sqlQry, new ArrayList());
}

/**
* 执行update/insert/delete语句
*
* @param sqlQry
* 执行的SQL(参数格式 :参数名)
* @param params
* 参数Map
* @return 执行成功笔数
*/
public int executeUpdate(String sqlQry, Map params) {
int count = 0;
try {
this.sqlQry = sqlQry;
this.params = params;
this.size = -1;
this.start = -1;
setParams();
count = helper.createStatement().executeUpdate(sqlQry);
} catch (SQLException e) {
log.error(e.toString(), e);
} finally {
log.debug(sqlQry);
if (!helper.trans) {
try {
helper.commit();
} catch (SQLException e) {
log.error(e.getMessage(), e);
}
close();
}
}
return count;
}

/**
* 执行update/insert/delete语句
*
* @param sqlQry
* 执行SQL(参数用 代替)
* @param params
* 参数List

*
可以是数组,也可以不传入

* 如果不传入代表SQL中没有参数

* @return 执行成功笔数
*/
public int executeUpdate(String sqlQry, List params) {
int count = 0;
try {
PreparedStatement pstmt = helper.createStatement(sqlQry);
setParams(pstmt, params);
count = pstmt.executeUpdate();
} catch (SQLException e) {
log.error(e.toString(), e);
} finally {
log.debug(sqlQry);
if (!helper.trans) {
try {
helper.commit();
} catch (SQLException e) {
log.error(e.getMessage(), e);
}
close();
}
}
return count;
}

/**
* {@link com.lingan.common.AbstractDao#executeUpdate(String,List)
* 查看executeUpdate}
*/
public int executeUpdate(String sqlQry, Object[] params) {
List list = new ArrayList();
if (params != null) {
for (Object o : params) {
lis