Spring jdbcTemplate示例
1. 单个插入
2. 批量插入
3. 单个更新
4. 单个删除
5. 批量删除
6. 查询（返回单个对象）
7. 查询（返回集合）
8. 查询（返回基本数据类型）
9. 查询（返回 String）
10. 调用存储过程
11. 批量插入--每次n条
12. 批量更新--每次n条
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import oracle.jdbc.OracleTypes;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCallback;
// 1. 单个插入
public int saveImageCharacters(HwCharacter po) throws Exception {
StringBuffer sql = new StringBuffer(100);
sql.append("INSERT INTO HW_CHARACTER(CHARACTER_ID, IMAGE_ID, CH, ");
sql.append("CREATE_TIME) VALUES(?, ?, ?, ?)");
Object[] params = new Object[] { po.getCharacterId(), po.getImageId(),
po.getCh(), po.getCreateTime() };
return getJdbcTemplate().update(sql.toString(), params);
}
// 2. 批量插入
public int batchSave(final List<HwDept> list) throws Exception {
StringBuffer sql = new StringBuffer(150);
sql.append("INSERT INTO HW_DEPT(");
sql.append("DEPT_ID, DEPT_NAME, DEPT_LEVEL, MANAGE_LEVEL, PARENT_ID");
sql.append(")");
sql.append("VALUES(?, ?, ?, ?, ?)");
return getJdbcTemplate().batchUpdate(sql.toString(),
new BatchPreparedStatementSetter() {
@Override
public void setValues(PreparedStatement ps, int i)
throws SQLException {
ps.setString(1, list.get(i).getDeptId());
ps.setString(2, list.get(i).getDeptName());
ps.setString(3, list.get(i).getDeptLevel());
ps.setString(4, list.get(i).getManageLevel());
ps.setString(5, list.get(i).getParentId());
}
@Override
public int getBatchSize() {
return list.size();
}
}).length;
}
// 3. 更新
public int updateImageCharacters(String ch, String characterId,
String imageId) throws Exception {
StringBuffer sql = new StringBuffer(200);
sql.append("UPDATE HW_CHARACTER SET CH = ? ");
sql.append("WHERE CHARACTER_ID = ? AND IMAGE_ID = ?");
Object[] params = new Object[] { ch, characterId, imageId };
return getJdbcTemplate().update(sql.toString(), params);
}
// 4. 单个删除
public int deleteUserRoleByUserId(String userId) throws Exception {
String sql = "DELETE FROM SS_USER_ROLE WHERE USER_ID = ?";
return getJdbcTemplate().update(sql, new Object[] { userId });
}
// 5. 批量删除
public int batchDelete(final List<String> idList) throws Exception {
String sql = "DELETE FROM HW_DIAGNOSE_RULE_CUST WHERE CUST_RULE_ID = ?";
int[] res = getJdbcTemplate().batchUpdate(sql,
new BatchPreparedStatementSetter() {
@Override
public void setValues(PreparedStatement ps, int i)
throws SQLException {
ps.setString(1, idList.get(i));
}
@Override
public int getBatchSize() {
return idList.size();
}
});
return res.length;
}
// 6. 查询（返回单个对象）
public HwInstrument findById(String id) throws Exception {
String sql = "SELECT * FROM HW_INSTRUMENT WHERE INSTRUMENT_ID = ?";
final HwInstrument po = new HwInstrument();
getJdbcTemplate().query(sql.toString(), new Object[] { id },
new RowCallbackHandler() {
@Override
public void processRow(ResultSet rs) throws SQLException {
po.setInstrumentId(rs.getString("INSTRUMENT_ID"));
po.setInstrumentModel(rs.getString("INSTRUMENT_MODEL"));
po.setInstrumentNo(rs.getString("INSTRUMENT_NO"));
po.setInstrumentName(rs.getString("INSTRUMENT_NAME"));
po.setFactory(rs.getString("FACTORY"));
po.setCreateTime(rs.getTimestamp("CREATE_TIME"));
}
});
return po;
}
// 7. 查询（返回集合）
public List<HwUseLimit> findUseLimit() throws SQLException,
DataAccessException, Exception {
StringBuffer sql = new StringBuffer(100);
sql.append("SELECT LIMIT_ID, IS_LIMIT, LIMIT_DATE, USE_NOS ");
sql.append(" FROM HW_USE_LIMIT");
List<HwUseLimit> list = new ArrayList<HwUseLimit>(10);
list = getJdbcTemplate().query(sql.toString(),
new RowMapper<HwUseLimit>() {
@Override
public HwUseLimit mapRow(ResultSet rs, int index)
throws SQLException {
HwUseLimit ul = new HwUseLimit();
ul.setLimitId(rs.getString("LIMIT_ID"));
ul.setIsLimit(rs.getString("IS_LIMIT"));
ul.setLimitDate(rs.getString("LIMIT_DATE"));
ul.setUseNos(rs.getInt("USE_NOS"));
return ul;
}
});
return list;
}
// 8. 查询（返回基本数据类型）
public int findByLoginName(final String loginName) throws Exception {
int count = getJdbcTemplate().execute(new PreparedStatementCreator() {
@Override
public PreparedStatement createPreparedStatement(Connection conn)
throws SQLException {
String sql = "SELECT COUNT(ID) FROM SS_USER WHERE LOGIN_NAME = ?";
return conn.prepareStatement(sql);
}
}, new PreparedStatementCallback<Integer>() {
@Override
public Integer doInPreparedStatement(PreparedStatement pstmt)
throws SQLException, DataAccessException {
pstmt.setString(1, loginName);
pstmt.execute();
ResultSet rs = pstmt.getResultSet();
rs.next();
return rs.getInt(1);
}
});
return count;
}
// 9. 查询（返回 String）
public String getCharacterByImageId(String imageId) throws Exception {
String sql = "SELECT CH FROM HW_CHARACTER WHERE IMAGE_ID = ?";
Object[] params = new Object[] { imageId };
try {
return getJdbcTemplate().queryForObject(sql, params, String.class);
} catch (EmptyResultDataAccessException e) {
// EmptyResultDataAccessException : 防止返回空值时报异常
return "";
}
}
10. 调用存储过程
public String saveNewDatas() throws Exception {
log.info("Into BusBarSectionDAOImpl.saveNewDatas()");
// 调用存储过程
String sql = "{CALL P_COMPARE_BUSBARSECTION(?)}";
Object obj = this.jdbcTemplate.execute(sql,
new CallableStatementCallback<String>() {
@Override
public String doInCallableStatement(CallableStatement cs)
throws SQLException, DataAccessException {
// 设置出参
cs.registerOutParameter(1, OracleTypes.VARCHAR);
cs.execute();
// 获取存储过程返回值
return cs.getString(1);
}
});
log.info("Out of BusBarSectionDAOImpl.saveNewDatas()");
return (String) obj;
}
11. 批量插入--每次n条
public int batchSaveNew(final List<BusBarSectionPO> list) throws Exception {
log.info("Into BusBarSectionDAOImpl.batchSaveNew(list)");
StringBuffer sql = new StringBuffer(200);
sql.append("INSERT INTO T_BUSBARSECTION_NEW(");
sql.append("ID, CIMID, NAME, X, Y, HEALTH_SITUATION, INODE, V_VALUE, ");
sql.append("V_QUALITY, A_VALUE, A_QUALITY, BAYID, VOLTAGELEVEL_ID, ");
sql.append("PATHNAME) ");
sql.append(" VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
sql.append("");
int count = this.jdbcTemplate.execute(sql.toString(),
new PreparedStatementCallback<Integer>() {
public Integer doInPreparedStatement(PreparedStatement ps)
throws SQLException, DataAccessException {
int length = list.size();
Connection conn = null;
try {
conn = ps.getConnection();
conn.setAutoCommit(false);
BusBarSectionPO po = null;
for (int i = 0; i < list.size(); i++) {
po = list.get(i);
ps.setString(1, MethodsUtils.getPKValue());
ps.setString(2, po.getCimId());
ps.setString(3, po.getName());
ps.setInt(4, po.getX());
ps.setInt(5, po.getY());
ps.setInt(6, po.getHealthSituation());
ps.setString(7, po.getiNode());
ps.setDouble(8, po.getvValue());
ps.setInt(9, po.getvQuality());
ps.setDouble(10, po.getaValue());
ps.setInt(11, po.getaQuality());
ps.setString(12, po.getBayId());
ps.setString(13, po.getVoltagelevelId());
ps.setString(14, po.getPathName());
ps.addBatch();
// 1000条记录insert一次
if (i % 1000 == 0) {
ps.executeBatch();
conn.commit();
}
}
// 最后insert剩余的数据
ps.executeBatch();
conn.commit();
return length;
} catch (SQLException e) {
log.error(
"Batch save BusBarSectionNew by cimId fail:"
+ e.getMessage(), e);
// 数据回滚
MethodsUtils.connectionRollback(conn);
throw e;
} catch (DataAccessException e) {
log.error(
"Batch save BusBarSectionNew by cimId fail:"
+ e.getMessage(), e);
// 数据回滚
MethodsUtils.connectionRollback(conn);
throw e;
} finally {
if (null != conn) {
// 如果用<aop:config> 来控制事务，需要把下面一行注掉，否则会报错
conn.setAutoCommit(true);
}
}
}
});
return count;
12. 批量更新--每次n条
public int batchUpdateByCimId(final List<BusBarSectionPO> list)
throws Exception {
log.info("Into BusBarSectionDAOImpl.batchUpdateByCimId(list)");
if (null == list || list.isEmpty()) {
log.info("Batch update BusBarSection by cimId,the list is empty.");
return 0;
}
StringBuffer sql = new StringBuffer(200);
sql.append("UPDATE T_BUSBARSECTION SET ");
sql.append("NAME = ?, X = ?, Y = ?, HEALTH_SITUATION = ?, ");
sql.append("INODE = ?, V_VALUE = ?, V_QUALITY = ?, A_VALUE = ?, ");
sql.append("A_QUALITY = ?, BAYID = ?, VOLTAGELEVEL_ID = ?, ");
sql.append("PATHNAME = ? ");
sql.append(" WHERE CIMID = ?");
int count = this.jdbcTemplate.execute(sql.toString(),
new PreparedStatementCallback<Integer>() {
public Integer doInPreparedStatement(PreparedStatement ps)
throws SQLException, DataAccessException {
int length = list.size();
Connection conn = null;
try {
conn = ps.getConnection();
conn.setAutoCommit(false);
BusBarSectionPO po = null;
for (int i = 0; i < list.size(); i++) {
po = list.get(i);
ps.setString(1, po.getName());
ps.setInt(2, po.getX());
ps.setInt(3, po.getY());
ps.setInt(4, po.getHealthSituation());
ps.setString(5, po.getiNode());
ps.setDouble(6, po.getvValue());
ps.setInt(7, po.getvQuality());
ps.setDouble(8, po.getaValue());
ps.setInt(9, po.getaQuality());
ps.setString(10, po.getBayId());
ps.setString(11, po.getVoltagelevelId());
ps.setString(12, po.getPathName());
ps.setString(13, po.getCimId());
ps.addBatch();
// 1000条记录更新一次
if (i % 1000 == 0) {
ps.executeBatch();
conn.commit();
}
}
// 最后更新剩余的数据
ps.executeBatch();
conn.commit();
return length;
} catch (SQLException e) {
log.error(
"Batch update BusBarSection by cimId fail:"
+ e.getMessage(), e);
// 数据回滚
MethodsUtils.connectionRollback(conn);
throw e;
} catch (DataAccessException e) {
log.error(
"Batch update BusBarSection by cimId fail:"
+ e.getMessage(), e);
// 数据回滚
MethodsUtils.connectionRollback(conn);
throw e;
} finally {
if (null != conn) {
// 如果用<aop:config> 来控制事务，需要把下面一行注掉，否则会报错
conn.setAutoCommit(true);
}
}
}
});
return count;
}
相关推荐
以下是常见的C++笔试面试题及其核心知识点解析，帮助您系统复习
计算机短期培训教案.pdf
计算机二级Access笔试题库.pdf
下是一份关于C++毕业答辩的心得总结，内容涵盖技术准备、答辩技巧和注意事项，供参考
内容概要：本文档详细介绍了英特尔为苹果公司构建的基于智能处理单元（IPU）的Cassandra集群的技术验证（PoC）。主要内容涵盖IPU存储用例、已建存储PoC、MEV到MMG400的过渡、苹果构建IPU-Cassandra集群的动机以及PoC开发进展。文档还探讨了硬件配置、软件环境设置、性能调优措施及其成果，特别是针对延迟和吞吐量的优化。此外，文档展示了六节点Cassandra集群的具体架构和测试结果，强调了成本和复杂性的降低。 适合人群：对分布式数据库系统、NoSQL数据库、IPU技术感兴趣的IT专业人员和技术管理人员。 使用场景及目标：适用于希望了解如何利用IPU提升Cassandra集群性能的企业技术人员。主要目标是展示如何通过IPU减少服务器部署的成本和功耗，同时提高数据处理效率。 其他说明：文档中涉及的内容属于机密级别，仅供特定授权人员查阅。文中提到的技术细节和测试结果对于评估IPU在大规模数据中心的应用潜力至关重要。
计算机二级考试C语言题.pdf
计算机发展史.pdf
计算机仿真技术系统的分析方法.pdf
yolo编程相关资源，python编程与YOLO算法组成的坐姿检测系统，功能介绍： 一：实时检测学生错误坐姿人数 二：通过前端阿里云平台显示上传数据，实现数据可视化
办公室网安全监控uptime-kuma，docker镜像离线压缩包
计算机课程设计-网络编程项目源码.zip
将该dll包放入项目并引用，可以操作打印机
杰奇2.3内核淡绿唯美小说网站源码 PC+手机版 自动采集 全站伪静态，送10.1版本关关采集器
计算机辅助教学.pdf
内容概要：本文详细介绍了如何利用天文相机和其他相关硬件设备搭建一套高画质、高帧率的流星监控系统，以及针对红色精灵闪电这一特殊自然现象的捕捉方法。文中不仅涵盖了硬件的选择标准如CMOS靶面尺寸、量子效率等重要参数，还提供了基于Python和OpenCV实现的基本监控代码示例，包括亮度突变检测、运动检测算法等关键技术点。此外，对于安装位置的选择、供电方式、成本控制等方面也有具体的指导建议。 适用人群：对天文摄影感兴趣的爱好者，尤其是希望捕捉流星和红色精灵闪电等瞬时天文现象的专业人士或业余玩家。 使用场景及目标：适用于希望搭建个人天文观测站，用于科学研究或个人兴趣爱好的场景。目标是能够稳定可靠地捕捉到流星和红色精灵闪电等难以捉摸的天文现象，为研究提供高质量的数据资料。 其他说明：文中提到的一些技术和方法虽然较为复杂，但对于有一定编程基础和技术动手能力的人来说是非常实用的参考资料。同时，文中提供的省钱技巧也为预算有限的用户提供了一些有价值的建议。
时间序列分析-基于R(第2版)习题数据
内容概要：本文详细介绍了如何使用LabVIEW通过网口读取阿特拉斯PM4000控制器的扭矩值。主要内容涵盖开放式通讯协议的理解、阿特拉斯调试软件和测试软件的应用、LabVIEW程序的具体实现步骤，包括初始化网络连接、发送读取扭矩值命令、接收并解析扭矩值数据，以及关闭网络连接。文中还提供了多个调试技巧和注意事项，如硬件接线配置、数据解析方法、常见错误及其解决办法，以及性能优化建议。 适合人群：从事工业自动化领域的工程师和技术人员，尤其是那些需要集成阿特拉斯设备并与之进行数据交互的专业人士。 使用场景及目标：适用于需要实时监控和采集阿特拉斯PM4000控制器扭矩值的工业应用场景，旨在提高数据采集效率和准确性，确保设备运行状态的良好监测。 其他说明：文中提供的代码片段和调试经验有助于快速定位和解决问题，提升开发效率。此外，还强调了数据解析过程中需要注意的细节，如字节序问题和超时设置等。
计算机二级VB重点知识点解析.pdf
计算机二级c语言(操作题105套其余参考).pdf