<!-- 配置jdbc模板类 --><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"></property></bean><!-- 配置 NamedParameterJdbcTemplate，该对象可以使用具名参数。但它没有无参构造器，所以必须为其制定构造参数，这里指定的是出c3p0数据源--><bean id="namedParameterJdbcTemplate"class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate"><constructor-arg ref="dataSource"></constructor-arg></bean>

public class BaseService {// JdbcTemplate 对象作为构造器参数初始化
    @Autowiredprotected NamedParameterJdbcTemplate namedParameterJdbcTemplate;/*** 数据查询* * @param sql* @param object* @return*/@SuppressWarnings("rawtypes")public List<?> query(String sql, Object object) {// BeanPropertySqlParameterSource封装了一个JavaBean对象，通过JavaBean对象属性来决定命名参数的值SqlParameterSource source = new BeanPropertySqlParameterSource(object);@SuppressWarnings("unchecked")// BeanPropertyRowMapper自动将一行数据映射到指定类的实例中 它首先将这个类实例化，然后通过名称匹配的方式，映射到属性中去List<?> list = namedParameterJdbcTemplate.query(sql, source, new BeanPropertyRowMapper(object.getClass()));return list;}/*** 数据添加、删除、修改* * @param sql* @param object* @return*/@SuppressWarnings("unchecked")public int excute(String sql, Object object) {if (object != null) {// 判断类型if (object instanceof Map) {return namedParameterJdbcTemplate.update(sql, (Map<String, ?>) object);} else {BeanPropertySqlParameterSource source = new BeanPropertySqlParameterSource(object);// 返回对象return namedParameterJdbcTemplate.update(sql, source);}} else {return namedParameterJdbcTemplate.getJdbcOperations().update(sql);}}/*** 查询记录数* * @param sql* @param object* @return*/public int queryCount(String sql, Object object) {BeanPropertySqlParameterSource source = null;if (object != null) {source = new BeanPropertySqlParameterSource(object);}return namedParameterJdbcTemplate.queryForObject(sql, source, Integer.class);}}

/*** 用户 服务类接口实现*/
@Service
public class IUserServiceImpl extends BaseService implements IUserService {public final static org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(IUserServiceImpl.class);/*** 查询用户*/@Overridepublic Object queryUser(String sql, Object object) {User user = new User();sql = "select suser as username,spassword as password,tcreatetime as createtime,cisenabled as enabled,cauthorize as authorize from sys_user";　　　　　// String sqls = "select suser as username,spassword as password,tcreatetime as createtime,cisenabled as enabled,cauthorize as authorize from sys_user where suser like '%:username%'";// 替换掉sql语句的条件// sqls = sqls.replace(":username", user.getUsername());@SuppressWarnings("unchecked")List<User> list = (List<User>) query(sql, user);return list;}/*** 添加用户*/@Overridepublic MsgBean addUser(User user) {MsgBean msg = new MsgBean();try {String sql = " insert into sys_user (suser,spassword,tcreatetime,cisenabled,cauthorize) values(:username,:password,:createtime,:enabled,:authorize)";// 添加新用户是自动取得时间// user.setCreatetime(DateUtil.getCurDate(null));
            excute(sql, user);msg.setFlag(true);msg.setText("ok");} catch (Exception e) {logger.error("出错的原因。。。" + e.getMessage());}return msg;}
/*** 修改用户*/@Overridepublic MsgBean updateUser(User user) {MsgBean msg = new MsgBean();try {String sql = " update sys_user set spassword=:password,tcreatetime=:createtime,cisenabled=:enabled,cauthorize=:authorize where suser=:username";excute(sql, user);msg.setFlag(true);msg.setText("ok");} catch (Exception e) {logger.error("出错的原因。。。" + e.getMessage());}return msg;}
/*** 删除用户*/@Overridepublic MsgBean deleteUser(String username) {MsgBean msg = new MsgBean();try {String sql = "delete from sys_user where suser =':username'";if (username != null && username.length() != 0) {sql = sql.replace(":username", username);}else {msg.setFlag(false);msg.setText("未知原因，删除失败");return msg;}excute(sql, null);msg.setFlag(true);msg.setText("ok");} catch (Exception e) {logger.error("出错的原因。。。" + e.getMessage());}return msg;}
}

/*** 用户控制层*/
@Controller
public class UserController {private static final Log logger = LogFactory.getLog(UserController.class);@Autowiredprivate IUserService userService;/*** 用户查询* * @param request* @param response* @return*/@ResponseBody@RequestMapping("/queryuser")public Object queryUserList(HttpServletRequest request, HttpServletResponse response) {User user = new User();// 模糊查询传来的值// String username = request.getParameter("username");// // 判断字符串是否为空// if (StringUtil.isBlank(username)) {// // 若为空替换为空字符串// username = "";// }// user.setUsername(username);
Object obj = userService.queryUser(null, user);return obj;}/*** 用户添加* * @param user* @return*/@ResponseBody@RequestMapping("/adduser")public MsgBean addUser(User user) {MsgBean msg = null;try {msg = userService.addUser(user);} catch (Exception e) {logger.error("出错的原因 ：" + e.getMessage());}return msg;}/*** 用户修改* * @param user* @return*/@ResponseBody@RequestMapping("/updateuser")public MsgBean updateUser(User user) {MsgBean msg = null;try {msg = userService.updateUser(user);} catch (Exception e) {logger.error("出错的原因 ：" + e.getMessage());}return msg;}/*** 用户删除* * @param username* @return*/@ResponseBody@RequestMapping("/deleteuser")public MsgBean deleteUser(@RequestParam("username") String username) {MsgBean msg = null;try {msg = userService.deleteUser(username);} catch (Exception e) {logger.error("出错的原因 ：" + e.getMessage());}return msg;}
}