package com.shsxt;import com.shsxt.po.Account;
import com.sun.xml.internal.bind.v2.model.core.ID;
import org.apache.commons.lang3.StringUtils;
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;import javax.annotation.Resource;
import javax.lang.model.element.Name;
import java.math.BigDecimal;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
@Repository
public class AccountDaoImpl implements AccountDao {@Resourceprivate JdbcTemplate jdbcTemplate;/*** 添加记录返回受影响行数* @param account* @return*/@Overridepublic Integer saveAccount(Account account) {String sql="insert into account (name,type,money,remark,create_time,update_time,userId) values(?,?,?,?,?,?,?)";return jdbcTemplate.update(sql,account.getName(),account.getType(),account.getMoney(),account.getRemark(),account.getCreate_time(),account.getUpdate_time(),account.getUserId());}/*** 添加记录返回主键* @param account* @return*/@Overridepublic Integer saveAccountHasPrimaryKey(Account account) {String sql="insert into account (name,type,money,remark,create_time,update_time,userId) values(?,?,?,?,?,?,?)";KeyHolder keyHolder=new GeneratedKeyHolder();jdbcTemplate.update(new PreparedStatementCreator() {@Overridepublic PreparedStatement createPreparedStatement(Connection con) throws SQLException {PreparedStatement ps=con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);ps.setString(1,account.getName());ps.setString(2,account.getType());ps.setBigDecimal(3,account.getMoney());ps.setString(4,account.getRemark());ps.setObject(5,account.getCreate_time());ps.setObject(6,account.getUpdate_time());ps.setInt(7,account.getUserId());return ps;}},keyHolder);return keyHolder.getKey().intValue();}/*** 批量添加记录* @param accounts* @return*/@Overridepublic Integer saveAccountsBatch(List<Account> accounts) {String sql="insert into account (name,type,money,remark,create_time,update_time,userId) values(?,?,?,?,?,?,?)";return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {@Overridepublic void setValues(PreparedStatement ps, int i) throws SQLException {ps.setString(1,accounts.get(i).getName());ps.setString(2,accounts.get(i).getType());ps.setBigDecimal(3,accounts.get(i).getMoney());ps.setString(4,accounts.get(i).getRemark());ps.setObject(5,accounts.get(i).getCreate_time());ps.setObject(6,accounts.get(i).getUpdate_time());ps.setInt(7,accounts.get(i).getUserId());}@Overridepublic int getBatchSize() {return accounts.size();}}).length;}/*** 统计账户记录-聚合查询* @param userId* @return*/@Overridepublic Integer countAccountsByUserId(Integer userId) {String sql="select count(1) from account where userId=?";return jdbcTemplate.queryForObject(sql,Integer.class,userId);}/*** 根据id查询记录详情* @param Id* @return*/@Overridepublic Account queryAccountById(Integer Id) {String sql="select id,userId,name,type,money,remark,update_time,create_time from account where id=?";return (Account) jdbcTemplate.queryForObject(sql,new Object[]{Id}, new RowMapper<Account>() {@Overridepublic Account mapRow(ResultSet rs, int rowNum) throws SQLException {Account account=new Account();account.setUpdate_time(rs.getDate("update_time"));account.setRemark(rs.getString("remark"));account.setType(rs.getString("type"));account.setMoney(rs.getBigDecimal("money"));account.setCreate_time(rs.getDate("create_time"));account.setId(rs.getInt("id"));account.setName(rs.getString("name"));account.setUserId(rs.getInt("userId"));return account;}});}/*** 多条件查询* @param userId* @param type* @param createTime* @param aname* @return*/@Overridepublic List<Account> queryAccountsByParams(Integer userId, String type, String createTime, String aname) {StringBuffer sql=new StringBuffer("select id,userId,name,type,money,remark,update_time,create_time from account where 1=1");List<Object> params=new ArrayList<>();if (null!=userId){sql.append(" and userId=?");params.add(userId);}if (StringUtils.isNotBlank(type)){sql.append(" and type=? ");params.add(type);}if (StringUtils.isNotBlank(createTime)){sql.append(" and createTime=?");params.add(createTime);}if (StringUtils.isNotBlank(aname)){sql.append(" and name=?");params.add(aname);}return  jdbcTemplate.query(sql.toString(), params.toArray(), new RowMapper<Account>() {@Overridepublic Account mapRow(ResultSet rs, int rowNum) throws SQLException {Account account=new Account();account.setId(rs.getInt("id"));account.setUserId(rs.getInt("userId"));account.setName(rs.getString("name"));account.setCreate_time(rs.getDate("create_time"));account.setMoney(rs.getBigDecimal("money"));account.setType(rs.getString("type"));account.setRemark(rs.getString("remark"));account.setUpdate_time(rs.getDate("update_time"));return account;}});}@Overridepublic Integer updateAccount(Account account) {String sql="update account set name=?,type=?,money=? where id=?";return jdbcTemplate.update(sql,account.getName(),account.getType(),account.getMoney(),account.getId());}/*** 批量更新* @param accounts* @return*/@Overridepublic Integer updateAccountsBatch(List<Account> accounts) {String sql="update account set name=?,type=?,money=? where id=?";return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {@Overridepublic void setValues(PreparedStatement ps, int i) throws SQLException {ps.setString(1,accounts.get(i).getName());ps.setString(2,accounts.get(i).getType());ps.setBigDecimal(3,accounts.get(i).getMoney());ps.setInt(4,accounts.get(i).getId());}@Overridepublic int getBatchSize() {return accounts.size();}}).length;}/*** 根据id删除记录* @param id* @return*/@Overridepublic Integer deleteAccountById(Integer id) {String sql="delete from account where id=?";return jdbcTemplate.update(sql,id);}/*** 批量删除* @param ids* @return*/@Overridepublic Integer deleteAccountsBatch(Integer[] ids) {String sql="delete from account where id=?";return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {@Overridepublic void setValues(PreparedStatement ps, int i) throws SQLException {ps.setInt(1,ids[i]);}@Overridepublic int getBatchSize() {return ids.length;}}).length;}@Overridepublic Integer inMoney(Integer sourceId, BigDecimal money) {String sql="update account set money=money-? where id=?";return jdbcTemplate.update(sql,money,sourceId);}@Overridepublic Integer outMoney(Integer targetId, BigDecimal money) {String sql="update account set money=money+? where id=?";return jdbcTemplate.update(sql,money,targetId);}
}