javaweb各种框架组合案例：springboot+jdbcTemplete+通用dao+restful

Posted 2022-03-15 xiaogblog

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了javaweb各种框架组合案例：springboot+jdbcTemplete+通用dao+restful相关的知识，希望对你有一定的参考价值。

一、介绍

1.springboot是spring项目的总结+整合

　　当我们搭smm,ssh,ssjdbc等组合框架时，各种配置不胜其烦，不仅是配置问题，在添加各种依赖时也是让人头疼，关键有些jar包之间还会出现冲突，让你的项目出现难以解决的问题。基于这种情况，springboot横空出世，在考虑到Struts控制层框架有漏洞，springboot放弃（大多数企业同样如此）了Struts，转而代之是springMVC，不过，springboot是自动集成springMVC的，不需要任何配置，不需要任何依赖，直接使用各种控制层注解。springboot是springcloud的基础，是开启微服务时代的钥匙。

二、新建springboot工程

1. 使用idea2019新建project，选择spring Initializr，next

技术图片

2. 填写坐标信息，next

技术图片

3. Developer Tools选择Lombok， Web选择Spring Web Starter，SQL选择JDBC API、mysql Driver，next

技术图片

lombok是为了省去实体类中getter/setter方法，使之在运行时动态添加getter/setter

4. 填写项目名已经存放位置，finish

技术图片

三、项目构建

1. 数据库准备（两张表，分别是user用户表和phone手机表，且是一对多关系）

create database ssdj;

CREATE TABLE `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`password` varchar(255) DEFAULT NULL,
`username` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

CREATE TABLE `phone` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `brand` varchar(255) DEFAULT NULL,
  `user_id` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `FK_8t3jhwmmlxpq3qcwcy1a3alts` (`user_id`),
  CONSTRAINT `FK_8t3jhwmmlxpq3qcwcy1a3alts` FOREIGN KEY (`user_id`) REFERENCES `user` (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

insert into user(username,password) values(1001,123);

insert into phone(brand,user_id) values (‘华为‘,1),(‘iphone‘,1);

2. pom.xml（不用动，默认）

3. 配置文件

　　application.properties

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/ssdj?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
spring.datasource.username=root
spring.datasource.password=root

　　数据库连接要添加时区，否则可能会报错

4.项目包结构

技术图片

　　分成util、core、entity、dao、service、controller等结构包

5. 需要一个SqlFactory工具类来制造动态SQL语句

package club.xcreeper.springboot_jdbctemplete.util;

import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SqlFactory 

    private String tableName;
    
    public Object[] params;
    
    public SqlFactory(Class<?> clazz) 
        tableName = clazz.getSimpleName().toLowerCase();
    
    
    private final static Logger logger = LoggerFactory.getLogger(SqlFactory.class);
    
    private Map<String,Object> objectToMap(Object entity) 
        Field[] fields = entity.getClass().getDeclaredFields();
        Map<String,Object> map = new HashMap<String,Object>();
        for(Field field : fields) 
            field.setAccessible(true);//允许访问属性
            Object value = null;
            try 
                value = field.get(entity);
             catch (IllegalArgumentException | IllegalAccessException e) 
                e.printStackTrace();
            
            if(value != null) 
                map.put(field.getName(), value);
            
        
        return map;
    
    
    public String getDeleteSql() 
        StringBuilder sql = new StringBuilder("delete from ").append(tableName).append(" where id = ?");
        logger.info(sql.toString());
        return sql.toString();
    
    
    public String getSelectOneSql() 
        StringBuilder sql = new StringBuilder("select * from ").append(tableName).append(" where id = ?");
        logger.info(sql.toString());
        return sql.toString();
    
    
    public String getInsertSql(Object entity) 
        Map<String,Object> map = this.objectToMap(entity);
        map.remove("id");
        params = new Object[map.size()];
        StringBuilder stringBuiler = new StringBuilder("insert into ").append(tableName).append("(");
        for(String key : map.keySet()) 
            stringBuiler.append(key).append(",");
        
        stringBuiler.deleteCharAt(stringBuiler.length()-1).append(") values (");
        int i = 0;
        for(String key : map.keySet()) 
            stringBuiler.append("?,");
            params[i] = map.get(key);
            i++;
        
        stringBuiler.deleteCharAt(stringBuiler.length()-1).append(")");
        map = null;
        logger.info(stringBuiler.toString());
        return stringBuiler.toString();
    
    
    public String getUpdateSql(Object entity) 
        Map<String,Object> map = this.objectToMap(entity);
        params = new Object[map.size()];
        params[params.length-1] = map.remove("id");
        StringBuilder stringBuiler = new StringBuilder("update ").append(tableName).append(" set ");
        int i = 0;
        for(String key : map.keySet()) 
            stringBuiler.append(key).append("=?,");
            params[i] = map.get(key);
            i++;
        
        stringBuiler.deleteCharAt(stringBuiler.length()-1).append(" where id = ?");
        map = null;
        logger.info(stringBuiler.toString());
        return stringBuiler.toString();
    
    
    public String getSelectList(Object entity) 
        Map<String,Object> map = this.objectToMap(entity);
        map.remove("id");
        params = new Object[map.size()];
        StringBuilder stringBuiler = new StringBuilder("select * from ").append(tableName).append(" where ");
        int i = 0;
        for(String key : map.keySet()) 
            stringBuiler.append(key).append("=? and ");
            params[i] = map.get(key);
            i++;
        
        stringBuiler.delete(stringBuiler.length()-4, stringBuiler.length());
        map = null;
        logger.info(stringBuiler.toString());
        return stringBuiler.toString();

SqlFactory

6.需要有一个通用的Dao接口及实现类来完成核心操作

package club.xcreeper.springboot_jdbctemplete.Core.dao;

import java.io.Serializable;
import java.util.List;

public interface CoreDao<T> 
    int insert(T t);
    int delete(Serializable id);
    int update(T t);
    T getOne(Serializable id);
    List<T> getList(T t);

CoreDao

package club.xcreeper.springboot_jdbctemplete.Core.dao.impl;

import club.xcreeper.springboot_jdbctemplete.Core.dao.CoreDao;
import club.xcreeper.springboot_jdbctemplete.util.SqlFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;

import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.List;

public class CoreDaoImpl<T> implements CoreDao<T> 

    private Class<T> clazz;

    private SqlFactory sqlFactory;

    @SuppressWarnings("unchecked")
    public CoreDaoImpl() 
        this.clazz =  (Class<T>)((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
        sqlFactory = new SqlFactory(this.clazz);
    

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public int insert(T t) 
        return jdbcTemplate.update(sqlFactory.getInsertSql(t),sqlFactory.params);
    

    @Override
    public int delete(Serializable id) 
        return jdbcTemplate.update(sqlFactory.getDeleteSql(),id);
    

    @Override
    public int update(T t) 
        return jdbcTemplate.update(sqlFactory.getUpdateSql(t),sqlFactory.params);
    

    @Override
    public T getOne(Serializable id) 
        return jdbcTemplate.queryForObject(sqlFactory.getSelectOneSql(),new BeanPropertyRowMapper<T>(this.clazz),id);

    

    @Override
    public List<T> getList(T t) 
        return jdbcTemplate.query(sqlFactory.getSelectList(t),new BeanPropertyRowMapper<T>(this.clazz),sqlFactory.params);

CoreDaoImpl

7. 实体类

package club.xcreeper.springboot_jdbctemplete.entity;

import lombok.Getter;
import lombok.Setter;
import lombok.ToString;

@ToString
public class User 
    @Setter
    @Getter
    private Integer id;
    @Setter
    @Getter
    private String username;
    @Setter
    @Getter
    private String password;

User

package club.xcreeper.springboot_jdbctemplete.entity;

import lombok.Getter;
import lombok.Setter;
import lombok.ToString;

@ToString
public class Phone 
    @[email protected]
    private Integer id;
    @[email protected]
    private String brand;
    @[email protected]
    private Integer user_id;

Phone

8. dao接口及其实现，只需继承核心dao即可

package club.xcreeper.springboot_jdbctemplete.dao;

import club.xcreeper.springboot_jdbctemplete.Core.dao.CoreDao;
import club.xcreeper.springboot_jdbctemplete.entity.User;

public interface UserDao extends CoreDao<User>

UserDao

package club.xcreeper.springboot_jdbctemplete.dao;

import club.xcreeper.springboot_jdbctemplete.Core.dao.CoreDao;
import club.xcreeper.springboot_jdbctemplete.entity.Phone;

public interface PhoneDao extends CoreDao<Phone>

PhoneDao

package club.xcreeper.springboot_jdbctemplete.dao.impl;

import club.xcreeper.springboot_jdbctemplete.Core.dao.impl.CoreDaoImpl;
import club.xcreeper.springboot_jdbctemplete.dao.UserDao;
import club.xcreeper.springboot_jdbctemplete.entity.User;
import org.springframework.stereotype.Repository;

@Repository
public class UserDaoImpl extends CoreDaoImpl<User> implements UserDao

UserDaoImpl

package club.xcreeper.springboot_jdbctemplete.dao.impl;

import club.xcreeper.springboot_jdbctemplete.Core.dao.impl.CoreDaoImpl;
import club.xcreeper.springboot_jdbctemplete.dao.PhoneDao;
import club.xcreeper.springboot_jdbctemplete.entity.Phone;
import org.springframework.stereotype.Repository;

@Repository
public class PhoneDaoImpl extends CoreDaoImpl<Phone> implements PhoneDao

PhoneDaoImpl

9. service接口及其实现

package club.xcreeper.springboot_jdbctemplete.service;

import club.xcreeper.springboot_jdbctemplete.entity.User;

import java.util.List;

public interface UserService 
    int insert(User user);
    int delete(int id);
    int update(User user);
    User getOne(int id);
    List<User> getList(User user);

UserService

package club.xcreeper.springboot_jdbctemplete.service;

import club.xcreeper.springboot_jdbctemplete.entity.Phone;

import java.util.List;

public interface PhoneService 
    int insert(Phone phone);
    int delete(int id);
    int update(Phone phone);
    Phone getOne(int id);
    List<Phone> getList(Phone phone);

PhoneService

package club.xcreeper.springboot_jdbctemplete.service.impl;

import club.xcreeper.springboot_jdbctemplete.dao.UserDao;
import club.xcreeper.springboot_jdbctemplete.entity.User;
import club.xcreeper.springboot_jdbctemplete.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class UserServiceImpl implements UserService 

    @Autowired
    private UserDao userDao;

    @Override
    public int insert(User user) 
        return userDao.insert(user);
    

    @Override
    public int delete(int id) 
        return userDao.delete(id);
    

    @Override
    public int update(User user) 
        return userDao.update(user);
    

    @Override
    public User getOne(int id) 
        return userDao.getOne(id);
    

    @Override
    public List<User> getList(User user) 
        return userDao.getList(user);

UserServiceImpl

package club.xcreeper.springboot_jdbctemplete.service.impl;

import club.xcreeper.springboot_jdbctemplete.dao.PhoneDao;
import club.xcreeper.springboot_jdbctemplete.entity.Phone;
import club.xcreeper.springboot_jdbctemplete.service.PhoneService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class PhoneServiceImpl implements PhoneService 

    @Autowired
    private PhoneDao phoneDao;

    @Override
    public int insert(Phone phone) 
        return phoneDao.insert(phone);
    

    @Override
    public int delete(int id) 
        return phoneDao.delete(id);
    

    @Override
    public int update(Phone phone) 
        return phoneDao.update(phone);
    

    @Override
    public Phone getOne(int id) 
        return phoneDao.getOne(id);
    

    @Override
    public List<Phone> getList(Phone phone) 
        return phoneDao.getList(phone);

PhoneServiceImpl

10. controller

package club.xcreeper.springboot_jdbctemplete.controller;

import club.xcreeper.springboot_jdbctemplete.entity.User;
import club.xcreeper.springboot_jdbctemplete.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController 

    @Autowired
    private UserService userService;

    @GetMapping(value = "/id")
    public User getOne(@PathVariable int id) 
        return userService.getOne(id);
    

    @GetMapping(params = "username","password","username!=","password!=")
    public List<User> getList(User user) 
        return userService.getList(user);

UserController

11. 启动项目，并用postman测试接口

技术图片

以上是关于javaweb各种框架组合案例：springboot+jdbcTemplete+通用dao+restful的主要内容，如果未能解决你的问题，请参考以下文章

JavaWeb1.3.4基础加强：注解案例-简单的测试框架

JavaWeb SpringBoo SSM 健身管理系统（源码+sql可运行《精品毕设》）6主要实现了用户登录会员管理教练管理课程管理器材管理会员充值物品遗失商品管理信息统计修改密码

JavaWeb--基本概念Web服务器与Tomcat

手把手教你用VUE开发后台管理系统：搭建SpringBoo 2.xt环境

有哪些Java web里的并发框架，有哪些？

JavaWeb框架SSH_Struts2_