Badger轻量级单表操作dao框架，提供分库分表，类型映射等功能。
例子中使用了lombok，简化bean。
<dependency>
<groupId>org.jfaster</groupId>
<artifactId>badger</artifactId>
<version>2.3</version>
</dependency>HikariConfig config = new HikariConfig();
config.setDriverClassName("com.mysql.jdbc.Driver");
config.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/store");
config.setUsername("yanpengfang");
config.setPassword("8888888888");
config.setMaximumPoolSize(10);
HikariDataSource dataSource = new HikariDataSource(config);
Badger badger = Badger.newInstance(dataSource);CREATE TABLE `driver` (
`driver_id` int(11) NOT NULL AUTO_INCREMENT,
`driver_name` varchar(64) DEFAULT NULL,
`age` int(11) DEFAULT NULL,
`type` int(11) DEFAULT NULL,
`create_date` timestamp NULL DEFAULT NULL,
`update_date` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`driver_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;public enum TypeEnum {
SELF("自营"), JOIN("加盟");
@Getter
private String desc;
TypeEnum(String desc) {
this.desc = desc;
}
}@Data
@Table(tableName = "driver")
public class Driver {
@Id
@Column
private int driverId;
@Column
private String driverName;
@Column
private int age;
@Column(convert = EnumIntegerConverter.class)
private TypeEnum type;
@Column
private Date createDate;
@Column
private Date updateDate;
}Table注解有tableName属性如果不指定默认是类的名转下划线，dataSourceName用于指定数据源工厂名称，如果是单库不用指定，如果是多库需要指定，指定注册到badger里的数据源工厂名称即可，见下文。 Column注解的name属性可以指定与数据库字段对应关系，如果不写默认是驼峰转下划线，convert属性是将bean的类型映射成数据库的类型，如果需要可以实现TypeConverter接口自行定义，默认提供EnumIntegerConverter、EnumStringConverter、FastJsonObjectConverter、IntArrayStringConverter、IntegerListStringConverter、IntegerSetStringConverter、StringArrayStringConverter、StringListStringConverter、StringSetStringConverter等。
/**
* 插入，插入所有字段，插入非空字段。
*/
@Test
public void insertTest() {
Date now = new Date();
Driver driver = new Driver();
driver.setAge(43);
driver.setDriverName("王叼蛋");
driver.setType(TypeEnum.JOIN);
driver.setCreateDate(now);
//保存非空字段并且回填自增主键id
badger.saveNotNull(driver);
driver = new Driver();
driver.setAge(43);
driver.setDriverName("刘叼蛋");
driver.setType(TypeEnum.SELF);
driver.setCreateDate(now);
driver.setUpdateDate(now);
//保存数据并且回填自增主键id
badger.save(driver);
System.out.println("司机ID:" + driver.getDriverId());
//忽略唯一索引冲突
badger.saveIgnore(driver);
System.out.println("司机ID:" + driver.getDriverId());
}badger还提供了saveIgnore方法，用于忽略唯一索引冲突
/**
* 根据id删除。
*/
@Test(expected = MappingException.class)
public void deleteTest() throws Exception {
badger.delete(Driver.class, 3);
}/**
* 根据条件删除
*/
@Test
public void deleteByConditionTest() {
DeleteStatement statement = badger.createDeteleStatement(Driver.class,
"type=? and age=?");
statement.addParam(TypeEnum.JOIN)
.addParam(43)
.execute();
//也可以简化写成如下，因为addParam提供了多个重载方法。
badger.createDeteleStatement(Driver.class, "type=? and age=?").addParam(TypeEnum.JOIN,43).execute();
}/**
* 根据id更新所有字段
*/
@Test
public void updateTest() {
Driver driver = badger.get(Driver.class, 14);
if (driver == null || driver.getDriverId() == 0) {
return;
}
driver.setAge(53);
driver.setType(TypeEnum.SELF);
badger.update(driver);
}/**
* 根据条件更新指定字段。
*/
@Test
public void updateByConditionTest() {
UpdateStatement statement = badger.createUpdateStatement(Order.class,
"age=?, update_date=?",
"type=? and driver_id=?");
statement.addParam(54)
.addParam(new Date())
.addParam(TypeEnum.SELF)
.addParam(13) //根据driver_id
.execute();
//简化写法
badger.createUpdateStatement(Order.class,"age=?, update_date=?","type=? and driver_id=?")
.addParam(54,new Date(),TypeEnum.SELF,13).execute();
}@Test
public void selectTest() {
Driver driver = badger.get(Driver.class, 14);
System.out.println(driver);
}/**
* 根据条件查询所有字段。
*/
@Test
public void selectAllByConditionTest() {
//根据条件查询所有字段
List<Driver> drivers = badger.createQuery(Driver.class,
"driver_id >=1 and driver_id <= ?")
.addParam(14)
.list();
System.out.println(drivers);
}/**
* 根据条件查询指定字段。
*/
@Test
public void selectColumnsByConditionTest() {
//根据条件查询指定字段
Query<Driver> queryDriver = badger.createQuery(Driver.class,
"age,type",
"type = ? and create_date < ?");
List<Driver> drivers = queryDriver.addParam(TypeEnum.SELF)
.addParam(new Date())
.list();
//简化写法
List<Driver> drivers = badger.createQuery(Driver.class, "age,type", "type = ? and create_date < ?")
.addParam(TypeEnum.SELF,new Date()).list();
System.out.println(drivers);
}in 查询可以使用后面介绍的Condition，省去了自己拼接逗号。
@Test
public void selectByConditionTest() {
//like查询
List<Driver> drivers = badger.createQuery(Driver.class, "driver_name like ?")
.addParam("%叼蛋%")
.list();
System.out.println(drivers);
//in 查询
drivers = badger.createQuery(Driver.class, "driver_id in (?,?,?)")
.addParam(17)
.addParam(19)
.addParam(20)
.list();
System.out.println(drivers);
}分页查询的pageIndex从1开始，1，2，3....
/**
* 分页查询
*/
@Test
public void selectByPageTest() {
Date now = new Date();
Date before = new Date(System.currentTimeMillis() - TimeUnit.HOURS.toMillis(10));
Query<Driver> query = badger.createQuery(Driver.class,
"create_date >= ? and create_date <= ?")
.addParam(before)
.addParam(now);
.setPageIndex(1) //相当于limit 0,10
.setPageSize(10)
//一共多少条
long count = query.count();
System.out.println("总条数:" + count);
List<Driver> drivers = query.list();
System.out.println(drivers);
}指定查询类型，允许自定义返回值的类型，例如返回单值等，也支持bean类型。
/**
* 指定查询返回的类型
*/
@Test
public void selectType() {
Integer avg = badger.createQuery(Driver.class, Integer.class,"avg(age)", "1=1 group by driver_id").getOne();
System.out.println(avg);
}
@Data
public class DriverExt {
@Column(name = "avgAge")
int avgAge;
@Column
int driverId;
}
/**
* 指定查询返回的类型
*/
@Test
public void selectBeanType() {
List<DriverExt> avg = badger.createQuery(Driver.class, DriverExt.class,"avg(age) as avgAge, driver_id", "1=1 group by driver_id").list();
System.out.println(avg);
}根据其他类定义好的表结构，进行一些操作，比如sum，min等等产生的字段，这些字段并不属于原来的表，但是是根据原来的表生成的。也可以通过上一节讲的，指定返回值类型实现。
@Data
@Extension(extend = Driver.class)
public class DriverExt {
@Column(name = "avgAge")
int avgAge;
@Column
int driverId;
}Query<DriverExt> query = badger.createQuery(DriverExt.class,
"avg(age) as avgAge, driver_id",
"1=1 group by driver_id");
List<DriverExt> driverExts = query.list();
System.out.println(driverExts);查询、删除、修改时条件可以直接传入，也可以动态的构建。此功能比较适合于动态条件和in查询，根据不同参数条件不同。静态条件也可以使用。Condition会自动跳过参数为null的字段，也可以自定义判断条件。
- 下面条件的例子相当于driver_id >=1 and driver_id <=30 忽略name, 因为值null。查询所有字段。
@Test
public void selectByLogicConditionTest() {
//根据条件查询所有字段
Condition condition = badger.createCondition()
.gte("driver_id", 1)
.and()
.lte("driver_id", 30)
.and()
.eq("name", null);
//
List<Driver> drivers = badger.createQuery(Driver.class, condition).list();
System.out.println(drivers);
}- 下面条件的例子相当于driver_id in(1,10,18)，只查询name和age字段。
@Test
public void selectByLogicConditionTest() {
//根据条件查询所有字段
List<Integer> driverIds = new ArrayList<>();
driverIds.add(1);
driverIds.add(10);
driverIds.add(18);
condition = badger.createCondition().in("driver_id", driverIds);
List<Driver> drivers1 = badger.createQuery(Driver.class, "name, age", condition).list();
System.out.println(drivers1);
}-
自定义过滤条件，如下条件相当于name="张三"，因为age的值为30小于35所以忽略了。
Condition condition = badger.createCondition() .eq("name", "张三") .and() .eq("age", 30, a-> a>35);
-
根据条件删除
@Test
public void selectByLogicConditionTest() {
Condition condition = badger.createCondition()
.gte("driver_id", 1)
.and()
.lte("driver_id", 30);
badger.createDeleteStatement(Driver.class, condition).execute();
}- 根据条件修改指定字段
@Test
public void selectByLogicConditionTest() {
Condition condition = badger.createCondition()
.eq("order_no", "P224378961549892939886")
.and()
.eq("driver_id", 15);
badger.createUpdateStatement(Order.class,
"money=?, update_date=?", condition.getSql())
.addParam(new BigDecimal("126"))
.addParam(new Date())
.addParam(condition.getParams())
.execute();
}- eq 等于
- ne 不等于
- gt 大于
- gte 大于等于
- lt 小于
- lte 小于等于
- groupBy 相当于group by
- orderByAsc 升序排序，如果是多个字段排序如condition.orderByAsc(col1,col2)，相当于 order by col1 asc, col2 asc
- orderByDesc 降序排序，如果是多个字段如condition.orderByDesc(col1,col2)，相当于order by col1 desc, col2 desc
- orderBy 可以为每个列指定排序规则，如condition.orderBy(OrderByColumn.asc("col1"), OrderByColumn.desc("col2"))，相当于order by col1 asc, col2 desc
- and 与
- or 或
- like 相当于like
- in 相当于in
- subLeft 相当于"("
- subRight 相当于")"
根据某个字段进行分库分表。如果根据某个字段进行分库分表则所有的操作必须带有分库分表字段。目前只支持单值分库分表，只要在分库分表的属性上打上@ShardColumn 即可，框架会自动提取值调用指定的分库分表算法。
CREATE TABLE `driver_order_0` (
`order_no` varchar(64) DEFAULT NULL,
`money` decimal(10,2) DEFAULT NULL,
`driver_id` int(11) DEFAULT NULL,
`create_date` timestamp NULL DEFAULT NULL,
`update_date` timestamp NULL DEFAULT NULL,
UNIQUE KEY `uniq_order_no` (`order_no`),
UNIQUE KEY `UK_order` (`driver_id`,`order_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
CREATE TABLE `driver_order_1` (
`order_no` varchar(64) DEFAULT NULL,
`money` decimal(10,2) DEFAULT NULL,
`driver_id` int(11) DEFAULT NULL,
`create_date` timestamp NULL DEFAULT NULL,
`update_date` timestamp NULL DEFAULT NULL,
UNIQUE KEY `uniq_order_no` (`order_no`),
UNIQUE KEY `UK_order` (`driver_id`,`order_no`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;ShardTable注解指定此表是需要分库或者分表的。其中tableShardStrategy是指定分表策略，实现TableShardStrategy接口；dbShardStrategy是指定分库策略，实现DatasourceShardStrategy接口。两种可以同时存在也可以只存在其一。下面的例子是把分库策略暂时注释掉，只实现分表功能，分库功能会在后续演示。
/**
* 分表分库
* @author yanpengfang
* @create 2019-01-31 9:41 PM
*/
@ShardTable(tables = {"driver_order_0", "driver_order_1"},
tableShardStrategy = Order.OrderTableShardStrategy.class
/*,dbShardStrategy = Order.OrderDataSourceShardStrategy.class*/)
@Data
public class Order {
@Id
@Column
private String orderNo;
@Column
private BigDecimal money;
@ShardColumn
@Column
private int driverId;
@Column
private Date createDate;
@Column
private Date updateDate;
public static class OrderTableShardStrategy implements TableShardStrategy<Integer> {
@Override
public String shardSingle(List<String> tables, Integer shardValue) {
int mod = shardValue % 2;
for (String table : tables) {
if (table.endsWith("_" + mod)) {
return table;
}
}
return tables.get(0);
}
}
/*public static class OrderDataSourceShardStrategy implements DataSourceShardStrategy<Integer> {
@Override
public String shardSingle(Integer shardValue) {
int mod = shardValue % 2;
return "db_" + mod;
}
}*/
}以插入为例。所有的操作都和不分表的操作一样，直接使用即可，分库分表的动作都由框架层实现，用户只需要指定自己的分库分表算法即可。
/**
* 插入唯一索引冲突忽略。
*/
@Test
public void insertTest() {
Order order = new Order();
order.setOrderNo("P22437896" + System.currentTimeMillis());
System.out.println("订单号:" + order.getOrderNo());
//根据driver_id分表，则按照例子的算法应该分到driver_order_1表
order.setDriverId(13);
order.setMoney(new BigDecimal("189.02"));
order.setUpdateDate(now);
order.setCreateDate(now);
//忽略唯一索引冲突
badger.saveIgnore(order);
}按照如下配置Badger，然后将上一节中定义的Order类中的分库策略注释打开，就可以实现分库了。分库和分表可以同时使用，也可以只使用其中之一。实现分库算法时，根据业务需要返回在badger中事先注册好的连接池的名称即可。例如下面的例子，注册了两个连接池，名字分别叫db_0和db_1。
HikariConfig config = new HikariConfig();
config.setDriverClassName("com.mysql.jdbc.Driver");
config.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/store");
config.setUsername("yanpengfang");
config.setPassword("88888888");
config.setMaximumPoolSize(10);
HikariDataSource dataSource = new HikariDataSource(config);
HikariConfig config1 = new HikariConfig();
config1.setDriverClassName("com.mysql.jdbc.Driver");
config1.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/store1");
config1.setUsername("yanpengfang");
config1.setPassword("8888888");
config1.setMaximumPoolSize(10);
HikariDataSource dataSource1 = new HikariDataSource(config1);
Badger badger = Badger.newInstance();
//指定数据源工厂名称为db_0
badger.setDataSourceFactory(new SingleDataSourceFactory("db_0", dataSource));
//指定数据源工厂名称为db_1
badger.setDataSourceFactory(new SingleDataSourceFactory("db_1", dataSource1));如果使用了分库分表功能，框架会自动根据@ShardColumn获取分库分表的值，则任何db操作都必须带上分库分表字段，但是存在一些特殊情况，比如分了10张表，有一种需求是遍历这10张表，那么这样查询条件就比较麻烦了，badger支持手动指定分库分表的值，手动指定会覆盖框架提取的值。
/**
* 插入 手动指定分库分表字段
*/
@Test
public void insertManualShardTest() {
Date now = new Date();
Driver driver = new Driver();
driver.setAge(47);
driver.setDriverName("指定分表");
driver.setType(TypeEnum.SELF);
driver.setCreateDate(now);
driver.setUpdateDate(now);
//保存数据并且回填自增主键id
badger.save(driver);
System.out.println("司机ID:" + driver.getDriverId());
Order order = new Order();
order.setOrderNo("P22437896" + System.currentTimeMillis());
System.out.println("订单号:" + order.getOrderNo());
order.setDriverId(driver.getDriverId());
order.setMoney(new BigDecimal("189.02"));
order.setUpdateDate(now);
order.setCreateDate(now);
//忽略唯一索引冲突, 并且指定分库分表的值为11，会覆盖系统提取的值。
badger.saveIgnore(order, 11);
}只需要在保存的时候指定一个分库分表的值。同理根据id更新、查找和删除，只需要在方法里传入指定的分库分表值即可。
/**
* 根据条件查询，查询指定字段。
*/
@Test
public void selectManualShardByConditionTest() {
//根据条件查询所有字段
Query<Order> query = badger.createQuery(Order.class, "order_no=?");
//指定分库分表字段的值为11，如果不指定则查询条件必须带有driverId，因为是按照driverId分库分表，手动指定会覆盖程序提取。
Order order = query.addParam("P224378961552032130141")
.setShardValue(11)
.getOne();
System.out.println(order);
}只需要在查询的时候调用setShardValue方法指定分库分表的值即可，根据条件删除、修改也是一样。
指定MasterSlaveDataSourceFactory数据源工厂，则查询语句自动走从库。
HikariConfig config = new HikariConfig();
config.setDriverClassName("com.mysql.jdbc.Driver");
config.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/store");
config.setUsername("yanpengfang");
config.setPassword("8888888");
config.setMaximumPoolSize(10);
HikariDataSource dataSource = new HikariDataSource(config);
HikariConfig config1 = new HikariConfig();
config1.setDriverClassName("com.mysql.jdbc.Driver");
config1.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/store1");
config1.setUsername("yanpengfang");
config1.setPassword("88888888");
config1.setMaximumPoolSize(10);
HikariDataSource dataSource1 = new HikariDataSource(config1);
Badger badger = Badger.newInstance();
badger.setDataSourceFactory(new MasterSlaveDataSourceFactory(dataSource,Collections.singletonList(dataSource1)));/**
* 根据id更新所有字段。
*/
@Test
public void updateTest() {
Driver driver = badger.getFromMaster(Driver.class, 14);
System.out.println(driver);
}/**
* 根据条件查询，查询指定字段。
*/
@Test
public void selectByConditionTest() {
//根据条件查询所有字段
List<Driver> driver = badger.createQuery(Driver.class,
"driver_id >=1 and driver_id <= ?")
.addParam(14)
.userMaster()
.list();
System.out.println(drivers);
}Badger既实现了自己的事务管理，同时也支持spring的事务管理器，支持spring的事务传播机制。使用其中一种即可。
实现TransactionAction方法，在这个方法中把要执行的一系列事务操作放在其中。
/**
* badger事务
*/
@Test(expected = MappingException.class)
public void transactionTest() {
TransactionTemplate.execute(status -> {
badger.delete(Driver.class, 15);
//根据id删除，但是分库分表字段不是id则抛异常
badger.delete(Order.class, "P224378961549867525895");
});
}使用spring的事务管理器，同时支持spring的事务传递机制。springboot同样可以使用。
<!--spring事务管理器-->
<dependency>
<groupId>org.jfaster</groupId>
<artifactId>badger-spring-transaction</artifactId>
<version>1.7</version>
<exclusions>
<exclusion>
<groupId>org.jfaster</groupId>
<artifactId>badger</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.1.4.RELEASE</version>
</dependency>
<dependency>
<groupId>org.jfaster</groupId>
<artifactId>badger</artifactId>
<version>2.3</version>
</dependency><?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd"
>
<context:component-scan base-package="org.jfaster.test"/>
<!-- 加载db配置文件 -->
<context:property-placeholder location="classpath*:*.properties" ignore-unresolvable="true"/>
<bean id="hikariConfig" class="com.zaxxer.hikari.HikariConfig">
<!--poolName属性自定义即可-->
<property name="poolName" value="springHikariCP"/>
<property name="driverClassName" value="${jdbc.driver}"/>
<property name="maximumPoolSize" value="${jdbc.maximumPoolSize}"/>
<property name="jdbcUrl" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<!-- HikariCP dataSource配置 -->
<bean id="hikaricpDataSource" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close">
<constructor-arg ref="hikariConfig"/>
</bean>
<!-- 注册事务管理类 -->
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="hikaricpDataSource"/>
</bean>
<!-- 开启事务行为 -->
<tx:annotation-driven/>
<!--初始化badger-->
<bean id="badger" class="org.jfaster.badger.Badger" factory-method="newInstance">
<property name="dataSource" ref="hikaricpDataSource"/>
<!--设置事务管理器为spring-->
<property name="transactionManager" value="spring"/>
</bean>
</beans>/**
*
* @author yanpengfang
* @create 2019-02-13 10:27 AM
*/
@Repository
public class DriverDao {
@Resource
private Badger badger;
public int deleteDriverById(int driverId) {
return badger.delete(Driver.class, driverId);
}
}/**
*
* @author yanpengfang
* @create 2019-02-13 10:27 AM
*/
@Repository
public class DriverOrderDao {
@Resource
private Badger badger;
public int deleteDriverOrderByOrderNo(String orderNo) {
return badger.delete(Order.class, orderNo);
}
}/**
*
* @author yanpengfang
* @create 2019-02-13 10:37 AM
*/
public interface DriverOrderService {
boolean deleteDriverAndOrder(int driverId, String orderNo);
}打上@Transactional注解
/**
*
* @author yanpengfang
* @create 2019-02-13 10:37 AM
*/
@Service
public class DriverOrderServiceImpl implements DriverOrderService {
@Resource
private DriverDao driverDao;
@Resource
private DriverOrderDao driverOrderDao;
@Override
@Transactional
public boolean deleteDriverAndOrder(int driverId, String orderNo) {
return driverDao.deleteDriverById(driverId) > 0
&& driverOrderDao.deleteDriverOrderByOrderNo(orderNo) > 0;
}
}设置拦截器，可以在sql执行之前和之后做一些操作，比如统计sql的执行时间等等
badger.setInterceptor(new SqlInterceptor() {
@Override
public void before(String sql) {
System.out.println("sql:" + sql + " begin to execute");
SqlInterceptor.put("startTime", System.currentTimeMillis());
}
@Override
public void after(String sql) {
long startTime = SqlInterceptor.get("startTime", Long.class);
System.out.println("sql:" + sql + " execute success, execute time:" + (System.currentTimeMillis() - startTime));
}
@Override
public void error(String sql, Throwable e) {
System.out.println("sql:" + sql + " execute fail " + e.getMessage());
}
});自定义sql，不建议使用。脱离了单表操作，根据个人需要自定义sql。在自定义sql情况下，Badger不解析sql，所以不会重写表名，不支持分库分表。分表的信息需要自己实现，拼接到sql中。分库操作则需要指定库名。复杂sql查询可以拆分成多次单表查询。大表本身不建议join等操作。
/**
*
* @author yanpengfang
* @create 2019-02-11 4:00 PM
*/
@Data
public class DriverOrder {
private int driverId;
private String orderNo;
}@Test
public void selectBySelfDefine() {
SQLQuery<DriverOrder> query = badger.createSqlQuery(DriverOrder.class, "select a.driver_id,b.order_no from driver a join driver_order_1 b on a.driver_id=b.driver_id where a.driver_id=?");
query.addParam(13);
//query.setDataSourceName("xx"); 如果分库需要自己指定。
List<DriverOrder> driverOrders = query.list();
System.out.println(driverOrders);
}/**
* 自定义sql更新，不支持分库分表，分库分表信息得自己实现
*/
@Test
public void updateBySelfDefine() {
UpdateSqlStatement sqlStatement = badger.createUpdateSqlStatement("update driver set update_date=? where driver_id=?");
//sqlStatement.setDataSourceName("xx");如果分库需要自己指定。
sqlStatement.addParam(new Date())
.addParam(14)
.execute();
}插件只需要简单配置即可，不用再手动初始化Badger实例了，插件会根据配置自动生成Badger类。
请参考[https://github.com/fang-yan-peng/badger-spring-boot-starter]