springboot+springjdbc项目实战(1)

在java开发中访问数据库的框架有JPA,Mybatis,Hibernate,原生JDBC,个人都有很长使用经历.JPA,Hibernate作为纯OR框架,封装比较完整,几乎能解决所有数据访问的问题,但java语言远不如SQL使用方便灵活,差不多完全丧失了SQL灵活性.原生的JDBC使用成本稍高,灵活性很好.Mybatis作为不完全的OR映射框架,既保留了SQL的灵活,又实现部分的OR使用比较方便,近年在开发中使用的比例逐步提高.

个人认为在绝大多数项目中使用springJDBC也是一个不错的选择.以下代码针对有一定开发经验的读者,预备知识,java其础,数据库,springboot maven等

环境准备:eclipse或IDEA,mysql 搭建springboot环境
目录结构:


QQ截图20180713114748.png

pom.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.gzz</groupId>
    <artifactId>springbootjdbc</artifactId>
    <version>1.0</version>
    <packaging>jar</packaging>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.6.RELEASE</version>
        <relativePath />
    </parent>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!-- 测试工具 (可以不用) -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- 谷歌工具 (可以不用) -->
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>24.0-jre</version>
        </dependency>
        <!-- 简化代码 (可以不用) -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

application.yml

spring:
  datasource:
    driverClassName: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root

logback.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d[%F:%L][%p]:%m%n</pattern>
        </encoder>
    </appender>
    <logger name="org.springframework" level="ERROR"/>
    <logger name="com.netflix" level="ERROR"/>
    <root level="info">
        <appender-ref ref="STDOUT"/>
    </root>
</configuration>

只要对springJDBC稍加封装便可以得到非常灵活彪悍的基础工具类

数据访问公共类

package com.dl.notebook.common.base;

import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;

/**
 * @功能描述:dao类公共类
 * @author http://www.gaozz.club
 * @date 2018-07-13
 */
@Scope("prototype")
public class BaseDao {
    protected final Log logger = LogFactory.getLog(BaseDao.class);
    @Autowired
    protected JdbcTemplate jdbcTemplate;
    @Autowired
    protected NamedParameterJdbcTemplate nameJdbcTemplate;

    /**
     * @功能描述:分页
     */
    protected <T> Page<T> queryPage(String sql, BaseCondition cond, Class<T> clazz) {
        String countSQL = "SELECT count(1) FROM (" + sql + ") t";
        int rowCount = jdbcTemplate.queryForObject(countSQL, cond.getArray(), Integer.class);
        int pageSize = cond.getSize();
        int curPage = cond.getPage();
        int pageCount = rowCount % pageSize == 0 ? rowCount / pageSize : rowCount / pageSize + 1;
        String listSql = sql + " LIMIT " + curPage * pageSize + "," + pageSize;
        List<T> dataList = jdbcTemplate.query(listSql.toString(), cond.getArray(), new BeanPropertyRowMapper<T>(clazz));
        return new Page<T>(dataList, cond.getPage(), rowCount, cond.getSize(), pageCount);
    }

    /**
     * @功能描述:批操作
     */
    protected <T> int[] batchOperate(List<T> list, String sql) {
        SqlParameterSource[] params = new SqlParameterSource[list.size()];
        for (int i = 0; i < list.size(); i++) {
            params[i] = new BeanPropertySqlParameterSource(list.get(i));
        }
        return nameJdbcTemplate.batchUpdate(sql, params);
    }

    /**
     * @功能描述:插入记录反加主键
     */
    protected <T> long saveKey(T t, String sql, String id) {
        KeyHolder keyHolder = new GeneratedKeyHolder();
        SqlParameterSource params = new BeanPropertySqlParameterSource(t);
        nameJdbcTemplate.update(sql, params, keyHolder, new String[] { id });
        return keyHolder.getKey().longValue();
    }

}

分页工具

package com.dl.notebook.common.base;

import java.util.ArrayList;
import java.util.List;
/**
 * @功能描述:分页工具
 * @author http://www.gaozz.club
 * @date 2018-07-13
 */
public class Page<T> {
    private List<T> dataList = new ArrayList<>();// 数据列表
    private int pageSize = 10;// 页大小
    private long rowCount;// 记录数
    private int curpage = 0;// 当前页
    private int pageCount;// 总页数

    public Page(List<T> dataList, int curpage, long rowCount, int pagesize, int pageCount) {
        this.dataList.addAll(dataList);
        this.pageSize = pagesize;
        this.rowCount = rowCount;
        this.curpage = curpage;
        this.pageCount = pageCount;
    }

    public List<T> getDataList() {
        return dataList;
    }

    public void setDataList(List<T> dataList) {
        this.dataList = dataList;
    }

    public int getPageSize() {
        return pageSize;
    }

    public void setPageSize(int pageSize) {
        this.pageSize = pageSize;
    }

    public long getRowCount() {
        return rowCount;
    }

    public void setRowCount(long rowCount) {
        this.rowCount = rowCount;
    }

    public int getCurpage() {
        return curpage;
    }

    public void setCurpage(int curpage) {
        this.curpage = curpage;
    }

    public int getPageCount() {
        return pageCount;
    }

    public void setPageCount(int pageCount) {
        this.pageCount = pageCount;
    }

}

拼加查询条件的基础类这是非常核心的代码可以使得我的在程序中非常灵活的拼加查询条件大大简化我的开发,具体可参考测试类中的queryList

package com.dl.notebook.common.base;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * @功能说明:拼加页面查询条件的基础类
 * @author http://www.gaozz.club
 * @date 2018-02-15
 */

public abstract class BaseCondition {
    private List<Object> paramList = new ArrayList<Object>();// 参数值
    private StringBuffer condition = new StringBuffer();// 条件语句
    private Integer size = 10;// 页大小(每页记录条)
    private Integer page = 0;// 当前页码
 
 

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(String类型)
     */
    protected void add(String value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL) && !"".equals(value)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(Short类型)
     */
    protected void add(Short value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    protected void add(Byte value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(String类型)
     */
    protected void add(Float value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(Long类型)
     */

    protected void add(Long value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(Boolean类型)
     */
    protected void add(Boolean value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(BigDecimal类型)
     */
    protected void add(BigDecimal value, String strSQL) {
        if (null != strSQL && null != value && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(Integer类型)
     */
    protected void add(Integer value, String strSQL) {
        if (null != value && !"".equals(strSQL) && null != strSQL) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件使用等于大于小于....运算符(Date类型)
     */
    protected void add(Date value, String strSQL) {
        if (null != value && !"".equals(strSQL) && null != strSQL) {
            condition.append(" " + strSQL);
            paramList.add(value);
        }
    }

    /**
     * @功能: 拼加条件
     */
    protected void add(String strSQL) {
        if (null != strSQL && !"".equals(strSQL)) {
            condition.append(" " + strSQL);
        }
    }

    /**
     * @功能: 拼加条件
     */
    protected void add(List<?> ids, String strSQL) {
        if (null != strSQL && !"".equals(strSQL) && ids != null && ids.size() > 0) {
            condition.append(" " + strSQL + SqlUtil.ArrayToIn(ids));
        }
    }

    /**
     * @param value
     *            :属性名称
     * @param strSQL
     *            :参数SQL字符
     * @param posLike
     *            :字句中百分号出现位置
     * @return strSQL:拼加后SQL字符包括占位符
     * @功能: 拼加条件使用like关键字模糊查询时
     */
    protected void add(String value, String strSQL, int pos) {
        if (null != strSQL && null != value && !"".equals(strSQL) && !"".equals(value)) {
            condition.append(" " + strSQL);
            if (pos == 1) {
                paramList.add("%" + value);
            } else if (pos == 2) {
                paramList.add(value + "%");
            } else if (pos == 3) {
                paramList.add("%" + value + "%");
            }
        }
    }

    /**
     * @功能: 将List转为数组
     */
    public Object[] getArray() {
        return paramList.toArray();
    }

    /**
     * @功能: 取条件字符串
     */
    public String getCondition() {
        // 清除查询条件
        condition.setLength(0);
        paramList.clear();
        addCondition();
        return condition.toString();
    }

    /**
     * @功能: 拼加条件方法
     */
    public abstract void addCondition();

    public Integer getSize() {
        return size;
    }

    public void setSize(Integer size) {
        this.size = size;
    }

    public Integer getPage() {
        return page;
    }

    public void setPage(Integer page) {
        this.page = page;
    }
 
}

代码工具

package com.dl.notebook.common.base;

import java.text.SimpleDateFormat;
import java.util.List;

import com.google.common.base.Joiner;

/**
 * @功能描述:代码工具
 * @author http://www.gaozz.club
 * @date 2018-07-13
 */
public class SqlUtil {
    /**
     * @方法说明:数据库中执行的SQL语句
     */
    public static String showSql(String sql, Object[] obj) {
        String param;
        for (int j = 0; null != obj && j < obj.length; j++) {
            param = "null";
            if (null != obj[j]) {
                String cname = obj[j].getClass().getName();
                if (cname.contains("Date") || cname.contains("Timestamp")) {
                    param = "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(obj[j]) + "'";
                } else if (cname.contains("String")) {
                    param = "'" + (String) obj[j] + "'";
                } else {
                    param = obj[j].toString();
                }
            }
            sql = sql.replaceFirst("[?]", param);
        }
        return sql;
    }

    /**
     * @方法说明:把组数拼接成IN语句
     */
    public static String ArrayToIn(Long ids[]) {
        return new StringBuffer(" IN (").append(Joiner.on(",").join(ids)).append(")").toString();
    }

    /**
     * @方法说明:把组数拼接成IN语句
     */
    public static String ArrayToIn(Integer ids[]) {
        return new StringBuffer(" IN (").append(Joiner.on(",").join(ids)).append(")").toString();
    }

    /**
     * @方法说明:把组数拼接成IN语句
     */
    public static String ArrayToIn(String ids[]) {
        return new StringBuffer(" IN ('").append(Joiner.on("','").join(ids)).append("')").toString();
    }

    /**
     * @方法说明:把List拼接成IN语句(数值型)
     */
    public static String ArrayToIn(List<?> ids) {// 数值IN字符窜
        return new StringBuffer(" ('").append(Joiner.on("','").join(ids)).append("')").toString();
    }
}

至此我们的准备工作已完成下次我们来编写业务代码。

代码生成器源码

代码生成器演示

spring boot 2.x 实例源码

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 215,794评论 6赞 498
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,050评论 3赞 391
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 161,587评论 0赞 351
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 57,861评论 1赞 290
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,901评论 6赞 388
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,898评论 1赞 295
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,832评论 3赞 416
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,617评论 0赞 271
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,077评论 1赞 308
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,349评论 2赞 331
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,483评论 1赞 345
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,199评论 5赞 341
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,824评论 3赞 325
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,442评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,632评论 1赞 268
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,474评论 2赞 368
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,393评论 2赞 352

推荐阅读更多精彩内容

  • 行脚小记
    铜陵大通古镇，民国编《九华山志》中称为“九华山头天门”，也是江浙（下江）一呆佛教信徒朝礼地藏到场的一座重要驿站...
    波斯猫陶红阅读 211评论 0赞 1
  • 你对自己满意吗
    心血来潮下了荔枝，一个主播在开话题，大概意思是你对自己满意吗，我直接回复不满意，她问不满意什么地方，我说工作和生活...
    蒙面姑娘阅读 253评论 0赞 0