JdbcTempalte添加修改删除查询批量操作

dao接口

package com.haikang.spring5.jdbc.dao;import com.haikang.spring5.jdbc.pojo.User;import java.util.List;public interface UserDao {// 添加员工方法int addUser(User user);// 修改员工信息方法int updateUser(User user);// 删除员工信息方法int deleteUser(Integer id);// 查询返回某个值，返回表中总共记录数int countRow();// 查询Id为1，的邮箱String  findEmailById(Integer id);// 根据Id查询员工信息User findUserById(Integer id);// 查询所有员工信息List<User> fineAllUser();// 批量添加操作int[] batchAdd(List<Object[]> batchArgs);// 批量修改操作int[] batchUpdateUser(List<Object[]> batchArgs);// 批量删除操作int[] batchDelete(List<Object[]> batchArgs);
}

dao接口实现类

package com.haikang.spring5.jdbc.dao;import com.haikang.spring5.jdbc.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;import java.util.List;/*** @Author 海康* @Version 1.0*/
@Repository
public class UserDaoImpl implements UserDao{@Autowiredprivate JdbcTemplate jdbcTemplate;@Overridepublic int addUser(User user) {// 定义Sql语句String sql = "insert into t_user(username,password,age,sex,email) VALUES(?,?,?,?,?)";// 调用JdbcTemplate中update方法int result = jdbcTemplate.update(sql, user.getUserName(), user.getPassword(),user.getAge(), user.getSex(), user.getEmail());return result;}@Overridepublic int updateUser(User user) {// 定义Sql语句String sql = "update t_user set username=?,password=?,age=?,sex=?,email=? where id=?";// 调用JdbcTemplate中的update方法int result = jdbcTemplate.update(sql, user.getUserName(), user.getPassword(), user.getAge(),user.getSex(), user.getEmail(), user.getId());return result;}@Overridepublic int deleteUser(Integer id) {// 定义Sql语句String sql = "delete from t_user where id=?";// 调用JdbcTemplate中的delete方法int result = jdbcTemplate.update(sql, id);return result;}// 查询返回表中记录数@Overridepublic int countRow() {// 定义Sql语句String sql = "select count(*) from t_user";// 调用JdbcTemplate中的方法Integer query = jdbcTemplate.queryForObject(sql, Integer.class);return query;}// 根据Id查询邮箱@Overridepublic String findEmailById(Integer id) {// 定义SqlString sql = "select email from t_user where id=?";// 调用JdbcTemplate中的方法String email = jdbcTemplate.queryForObject(sql, String.class, id);return email;}// 根据Id查询员工信息@Overridepublic User findUserById(Integer id) {// 定义Sql语句String sql = "select * from t_user where id = ?";User user = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<User>(User.class), id);return user;}// 查询所有员工信息@Overridepublic List<User> fineAllUser() {// 定义SqlString sql = "select * from t_user";List<User> userList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));return userList;}@Overridepublic int[] batchAdd(List<Object[]> batchArgs) {// 定义Sql语句String sql = "insert into t_user(username,password,age,sex,email) VALUES(?,?,?,?,?)";// 调用JdbcTemplate中方法int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);return ints;}// 批量修改@Overridepublic int[] batchUpdateUser(List<Object[]> batchArgs) {// 定义Sql语句String sql = "update t_user set username=?,password=?,age=?,sex=?,email=? where id=?";int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);return ints;}@Overridepublic int[] batchDelete(List<Object[]> batchArgs) {// 定义Sql语句String sql = "delete from t_user where id=?";int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);return ints;}}

Service层

package com.haikang.spring5.jdbc.service;import com.haikang.spring5.jdbc.dao.UserDao;
import com.haikang.spring5.jdbc.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;/*** @Author 海康* @Version 1.0*/
@Service
public class UserService {@Autowiredprivate UserDao userDao;// 调用Dao层，添加一个员工public void addUser(User user){int result = userDao.addUser(user);System.out.println(result);}// 调用Dao层，修改员工方法public void updateUser(User user){int result = userDao.updateUser(user);System.out.println(result);}// 调用Dao层，删除员工方法public void deleteUser(Integer id){int result = userDao.deleteUser(id);System.out.println(result);}// 查询表中有多少条记录public void count(){int countRow = userDao.countRow();System.out.println(countRow);}// 根据Id查询email记录public String findEmailById(Integer id){String emailById = userDao.findEmailById(id);return emailById;}// 根据Id查询员工信息public User findUserById(Integer id){User userById = userDao.findUserById(id);return userById;}// 查询所有员工信息public List<User> findAllUser(){List<User> users = userDao.fineAllUser();return users;}// 批量添加多条记录public int[] batchAddUser(List<Object[]> batchArgs){int[] ints = userDao.batchAdd(batchArgs);return ints;}// 批量修改多条记录public int[] batchUpdate(List<Object[]> batchArgs){int[] ints = userDao.batchUpdateUser(batchArgs);return ints;}// 批量删除public int[] batchDelete(List<Object[]> batchArgs){int[] ints = userDao.batchDelete(batchArgs);return ints;}
}

test类

package com.haikang.spring5.jdbc.test;import com.haikang.spring5.jdbc.pojo.User;
import com.haikang.spring5.jdbc.service.UserService;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;/*** @Author 海康* @Version 1.0*/
public class JdbcTemplate {@Testpublic void test(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);userService.addUser(new User(null,"艾明","123",21,"女","123@qq.com"));}@Testpublic void testUpdate(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);userService.updateUser(new User(19,"艾明","1314",21,"女","123@qq.com"));}@Testpublic void testDelete(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);userService.deleteUser(19);}// 查询表中记录数@Testpublic void testCount(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);userService.count();}// 根据Id查询email记录@Testpublic void testEmail(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);String emailById = userService.findEmailById(1);System.out.println(emailById);}// 根据Id查询员工信息@Testpublic void testFindUserById(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);User userById = userService.findUserById(1);System.out.println(userById);}// 查询所有员工信息@Testpublic void testFindAllUser(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);List<User> allUser = userService.findAllUser();for (int i = 0; i < allUser.size(); i++) {System.out.println(allUser.get(i));}}// 批量添加多条记录@Testpublic void testBatch(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);Object[] obj1 = {"大理","123",21,"男","123@qq.com"};Object[] obj2 = {"大理","123",21,"男","123@qq.com"};Object[] obj3 = {"大理","123",21,"男","123@qq.com"};List<Object[]> batchArgs = new ArrayList<>();batchArgs.add(obj1);batchArgs.add(obj2);batchArgs.add(obj3);int[] ints = userService.batchAddUser(batchArgs);System.out.println(Arrays.toString(ints));}// 批量修改多条记录@Testpublic void testBatchUpdate(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);Object[] obj1 = {"大理","12dsfs3",21,"男","123@qq.com",20};Object[] obj2 = {"大理","12fds3",21,"男","123@qq.com",21};Object[] obj3 = {"大理","12sdf3",21,"男","123@qq.com",22};List<Object[]> batchArgs = new ArrayList<>();batchArgs.add(obj1);batchArgs.add(obj2);batchArgs.add(obj3);int[] ints = userService.batchUpdate(batchArgs);System.out.println(Arrays.toString(ints));}// 批量修改多条记录@Testpublic void testBatchDelete(){ApplicationContext context =new ClassPathXmlApplicationContext("bean1.xml");UserService userService = context.getBean("userService", UserService.class);Object[] obj1 = {20};Object[] obj2 = {21};Object[] obj3 = {22};List<Object[]> batchArgs = new ArrayList<>();batchArgs.add(obj1);batchArgs.add(obj2);batchArgs.add(obj3);int[] ints = userService.batchDelete(batchArgs);System.out.println(Arrays.toString(ints));}
}

JdbcTempalte添加修改删除查询批量操作相关推荐

CentOS7设置静态IP、搭建单机版FastDFS图片服务器、使用FastDFS-Client客户端进行简单测试、实现图片上传、实现商品添加修改删除
CentOS7设置静态IP.搭建单机版FastDFS图片服务器.使用FastDFS-Client客户端进行简单测试.实现图片上传.实现商品添加修改删除 CentOS7设置静态IP而且还可以上网 192 ...
es修改索引java_Elasticsearch添加修改删除索引文档案例分享
本文介绍如何采用bboss es添加/修改/删除/批量删除elasticsearch索引文档,直接看代码. 添加/修改文档 TAgentInfo agentInfo = new TAgentInfo( ...
asp.net 对xml文件的读写,添加,修改,删除操作
asp.net 对xml文件的读写,添加,修改,删除操作下面有代码调试正确 using System; using System.Collections; using System.Componen ...
wordpress怎么修改html,WordPress后台编辑器HTML模式界面中添加修改删除按钮
在WordPress编辑器HTML模式界面中添加按钮一文中,我大致介绍了怎么在后台添加一些自定义的按钮,本文则更为详细全面的对wordpress后台编辑器HTML模式下的按钮自定义进行详解,以让开发 ...
如何动态添加修改删除定时任务
如何动态添加修改删除定时任务 (1)思路说明: (a)首先这里我们需要重新认识一个类ThreadPoolTaskScheduler:线程池任务调度类,能够开启线程池进行任务调度. (b)ThreadP ...
iReport 5.添加修改删除jdbc
Jaspersoft iReport Designer 5.1.0 启动的时候以前的数据源jdbc找不到,报错:classnotfound:oracle.jdbc.driver.Oracl ...
delphi百度人脸搜索（支持人脸搜索、人脸库新增修改删除查询）
下载链接:https://download.csdn.net/download/liushenglin123/12550077 [delphi百度人脸搜索]支持人脸搜索.人脸库新增修改删除查询
Chrome浏览器设置header请求响应头使用 Chrome ModHeader插件，添加/修改/删除HTTP请求标头和响应标头
ModHeader,是一款可以添加/修改/删除请求标头和响应标头的浏览器插件 ModHeader插件功能 ModHeader插件支持添加/修改/删除请求标头和响应标头,并可以启用基于URL /资源类型 ...
VC6.0 MFC 列表框列表控件添加修改删除
VC6.0 MFC 列表框列表控件添加修改删除写在前面:列表框是很常用,并且很重要的一个控件,那么接下来,就跟随我的脚步,去探索它的奥秘吧! 一.未卜先知 1.编译运行后,点击"学 ...

JdbcTempalte添加修改删除查询批量操作

JdbcTempalte添加修改删除查询批量操作相关推荐

最新文章

热门文章