7 Commits

Author SHA1 Message Date
yhl452493373
54e2f9dffb 增加 String format(Sequences sequences, Integer minLength, String pattern)方法 2022-02-10 18:05:49 +08:00
yhl452493373
1a9a158126 update README 2022-02-10 11:28:52 +08:00
yhl452493373
81c9babb40 增加手动释放指定序号功能 2022-02-10 11:23:08 +08:00
杨黄林
c77088a7f5 更新 README.md 2022-02-01 15:36:38 +08:00
c6d828bf0f 更新 'README.md' 2022-02-01 07:31:38 +00:00
杨黄林
8046474df7 更新 README.md 2022-02-01 15:29:12 +08:00
杨黄林
e45e75c644 变更包名 2022-02-01 15:22:37 +08:00
16 changed files with 155 additions and 99 deletions

View File

@@ -8,15 +8,15 @@
使用方法: 使用方法:
+ 在项目中放置jar包的地方把seq-1.0.0.jar、seq-1.0.0-sources.jar、seq-1.0.0-pom.xml复制过去 + 在项目中放置jar包的地方把seq-1.1.0.jar、seq-1.1.0-sources.jar、seq-1.1.0-pom.xml复制过去
+ 在pom.xml中增加以下内容然后执行maven命令mvn clean + 在pom.xml中增加以下内容然后执行maven命令mvn clean
```xml ```xml
<build> <project>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.cdhncy</groupId> <groupId>com.yanghuanglin</groupId>
<artifactId>seq</artifactId> <artifactId>seq</artifactId>
<version>1.0.0</version> <version>1.0.0</version>
<exclusions> <exclusions>
@@ -34,6 +34,8 @@
</dependency> </dependency>
</dependencies> </dependencies>
<build>
<plugins>
<!-- 每次执行mvn clean时自动安装指定的jar包 --> <!-- 每次执行mvn clean时自动安装指定的jar包 -->
<plugin> <plugin>
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
@@ -48,11 +50,11 @@
</goals> </goals>
<configuration> <configuration>
<!-- ${project.basedir}表示当前项目的根目录 --> <!-- ${project.basedir}表示当前项目的根目录 -->
<file>${project.basedir}/lib/seq-1.0.0.jar</file> <file>${project.basedir}/lib/seq-1.1.0.jar</file>
<pomFile>${pom.basedir}/lib/seq-1.0.0-pom.xml</pomFile> <pomFile>${pom.basedir}/lib/seq-1.1.0-pom.xml</pomFile>
<sources>${project.basedir}/lib/seq-1.0.0-sources.jar</sources> <sources>${project.basedir}/lib/seq-1.1.0-sources.jar</sources>
<repositoryLayout>default</repositoryLayout> <repositoryLayout>default</repositoryLayout>
<groupId>com.cdhncy</groupId> <groupId>com.yanghuanglin</groupId>
<artifactId>seq</artifactId> <artifactId>seq</artifactId>
<version>1.0.0</version> <version>1.0.0</version>
<packaging>jar</packaging> <packaging>jar</packaging>
@@ -61,18 +63,20 @@
</execution> </execution>
</executions> </executions>
</plugin> </plugin>
</build> </plugins>
</build>
</project>
``` ```
+ springboot中配置方式一优先直接注入已有jdbcTemplate和transactionTemplate + springboot中配置方式一优先直接注入已有jdbcTemplate和transactionTemplate
```java ```java
package com.yang.springseq.config; package com.yanghuanglin.springseq.config;
import com.cdhncy.seq.config.GeneratorConfig; import com.yanghuanglin.seq.config.GeneratorConfig;
import com.cdhncy.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.cdhncy.seq.generator.Generator; import com.yanghuanglin.seq.generator.Generator;
import com.cdhncy.seq.generator.impl.SequencesGenerator; import com.yanghuanglin.seq.generator.impl.SequencesGenerator;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
@@ -138,16 +142,14 @@ public class SeqGeneratorConfig {
+ springboot中配置方式二注入已有的dataSource或自行构建dataSource通过dataSource自动生成jdbcTemplate和transactionTemplate + springboot中配置方式二注入已有的dataSource或自行构建dataSource通过dataSource自动生成jdbcTemplate和transactionTemplate
```java ```java
package com.yang.springseq.config; package com.yanghuanglin.springseq.config;
import com.cdhncy.seq.config.GeneratorConfig; import com.yanghuanglin.seq.config.GeneratorConfig;
import com.cdhncy.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.cdhncy.seq.generator.Generator; import com.yanghuanglin.seq.generator.Generator;
import com.cdhncy.seq.generator.impl.SequencesGenerator; import com.yanghuanglin.seq.generator.impl.SequencesGenerator;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.support.TransactionTemplate;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.sql.DataSource; import javax.sql.DataSource;
@@ -203,10 +205,10 @@ public class SeqGeneratorConfig {
+ 使用: + 使用:
```java ```java
package com.yang.springseq.config; package com.yanghuanglin.springseq.config;
import com.cdhncy.seq.generator.Generator; import com.yanghuanglin.seq.generator.Generator;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -277,7 +279,7 @@ GeneratorConfig配置项通过set方法设置
| transactionManager | org.springframework.jdbc.datasource.DataSourceTransactionManager | null | 事务管理器 | | transactionManager | org.springframework.jdbc.datasource.DataSourceTransactionManager | null | 事务管理器 |
| autoCreate | Boolean | true | 开启自动建表 | | autoCreate | Boolean | true | 开启自动建表 |
| step | Integer | 1 | 序号增加时的步长 | | step | Integer | 1 | 序号增加时的步长 |
| tableConfig | com.cdhncy.seq.config.TableConfig | TableConfig的默认配置 | 表配置 | | tableConfig | com.yanghuanglin.seq.config.TableConfig | TableConfig的默认配置 | 表配置 |
以上配置中jdbcTemplate和transactionTemplate优先级最高如果jdbcTemplate、transactionTemplate、dataSource、transactionManager同时配置则dataSource和transactionManager无效 以上配置中jdbcTemplate和transactionTemplate优先级最高如果jdbcTemplate、transactionTemplate、dataSource、transactionManager同时配置则dataSource和transactionManager无效
进行这几种组合dataSource+autoCreate+step+tableConfigjdbcTemplate+transactionTemplate+autoCreate+step+tableConfigjdbcTemplate+transactionManager+autoCreate+step+tableConfig 进行这几种组合dataSource+autoCreate+step+tableConfigjdbcTemplate+transactionTemplate+autoCreate+step+tableConfigjdbcTemplate+transactionManager+autoCreate+step+tableConfig
@@ -286,11 +288,11 @@ GeneratorConfig配置项通过set方法设置
Generator方法如下 Generator方法如下
```java ```java
package com.cdhncy.seq.generator; package com.yanghuanglin.seq.generator;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
import com.cdhncy.seq.po.SequencesUnlock; import com.yanghuanglin.seq.po.SequencesUnlock;
import com.cdhncy.seq.po.SequencesUnused; import com.yanghuanglin.seq.po.SequencesUnused;
import java.util.Date; import java.util.Date;

View File

@@ -2,9 +2,9 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>com.cdhncy</groupId> <groupId>com.yanghuanglin</groupId>
<artifactId>seq</artifactId> <artifactId>seq</artifactId>
<version>1.0.0</version> <version>1.1.0</version>
<name>seq</name> <name>seq</name>
<description>seq</description> <description>seq</description>
<properties> <properties>
@@ -34,6 +34,7 @@
<plugin> <plugin>
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId> <artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration> <configuration>
<source>8</source> <source>8</source>
<target>8</target> <target>8</target>

View File

@@ -1,4 +1,4 @@
package com.cdhncy.seq.config; package com.yanghuanglin.seq.config;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.jdbc.datasource.DataSourceTransactionManager;

View File

@@ -1,4 +1,4 @@
package com.cdhncy.seq.config; package com.yanghuanglin.seq.config;
/** /**
* 生成器对应的数据库表和字段配置 * 生成器对应的数据库表和字段配置

View File

@@ -1,6 +1,6 @@
package com.cdhncy.seq.dao; package com.yanghuanglin.seq.dao;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
/** /**
* @author yanghuanglin * @author yanghuanglin

View File

@@ -1,6 +1,6 @@
package com.cdhncy.seq.dao; package com.yanghuanglin.seq.dao;
import com.cdhncy.seq.po.SequencesUnlock; import com.yanghuanglin.seq.po.SequencesUnlock;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;

View File

@@ -1,6 +1,6 @@
package com.cdhncy.seq.dao; package com.yanghuanglin.seq.dao;
import com.cdhncy.seq.po.SequencesUnused; import com.yanghuanglin.seq.po.SequencesUnused;
import java.util.List; import java.util.List;
@@ -25,6 +25,11 @@ public interface SequencesUnusedDao {
*/ */
boolean delete(SequencesUnused sequencesUnused); boolean delete(SequencesUnused sequencesUnused);
/**
* 保存空闲序号
*/
boolean save(SequencesUnused sequencesUnused);
/** /**
* 批量保存空闲序号 * 批量保存空闲序号
*/ */

View File

@@ -1,8 +1,8 @@
package com.cdhncy.seq.dao.impl; package com.yanghuanglin.seq.dao.impl;
import com.cdhncy.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.cdhncy.seq.dao.SequencesDao; import com.yanghuanglin.seq.dao.SequencesDao;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
import org.springframework.dao.EmptyResultDataAccessException; import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
@@ -11,6 +11,7 @@ import org.springframework.jdbc.core.JdbcTemplate;
* @author yanghuanglin * @author yanghuanglin
* @since 2022/1/28 * @since 2022/1/28
*/ */
@SuppressWarnings("SqlResolve")
public class SequencesDaoImpl implements SequencesDao { public class SequencesDaoImpl implements SequencesDao {
private final JdbcTemplate jdbcTemplate; private final JdbcTemplate jdbcTemplate;
private final TableConfig tableConfig; private final TableConfig tableConfig;

View File

@@ -1,8 +1,8 @@
package com.cdhncy.seq.dao.impl; package com.yanghuanglin.seq.dao.impl;
import com.cdhncy.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.cdhncy.seq.dao.SequencesUnlockDao; import com.yanghuanglin.seq.dao.SequencesUnlockDao;
import com.cdhncy.seq.po.SequencesUnlock; import com.yanghuanglin.seq.po.SequencesUnlock;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper; import org.springframework.jdbc.core.RowMapper;
@@ -13,6 +13,7 @@ import java.util.List;
* @author yanghuanglin * @author yanghuanglin
* @since 2022/1/28 * @since 2022/1/28
*/ */
@SuppressWarnings("SqlResolve")
public class SequencesUnlockDaoImpl implements SequencesUnlockDao { public class SequencesUnlockDaoImpl implements SequencesUnlockDao {
private final JdbcTemplate jdbcTemplate; private final JdbcTemplate jdbcTemplate;
private final TableConfig tableConfig; private final TableConfig tableConfig;

View File

@@ -1,8 +1,8 @@
package com.cdhncy.seq.dao.impl; package com.yanghuanglin.seq.dao.impl;
import com.cdhncy.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.cdhncy.seq.dao.SequencesUnusedDao; import com.yanghuanglin.seq.dao.SequencesUnusedDao;
import com.cdhncy.seq.po.SequencesUnused; import com.yanghuanglin.seq.po.SequencesUnused;
import org.springframework.dao.EmptyResultDataAccessException; import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.BatchPreparedStatementSetter; import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
@@ -16,6 +16,7 @@ import java.util.List;
* @author yanghuanglin * @author yanghuanglin
* @since 2022/1/28 * @since 2022/1/28
*/ */
@SuppressWarnings("SqlResolve")
public class SequencesUnusedDaoImpl implements SequencesUnusedDao { public class SequencesUnusedDaoImpl implements SequencesUnusedDao {
private final JdbcTemplate jdbcTemplate; private final JdbcTemplate jdbcTemplate;
private final TableConfig tableConfig; private final TableConfig tableConfig;
@@ -55,6 +56,14 @@ public class SequencesUnusedDaoImpl implements SequencesUnusedDao {
return result != 0; return result != 0;
} }
@Override
public boolean save(SequencesUnused sequencesUnused) {
String sql = "insert into `%s_ununsed`(`%s`,`%s`,`%s`) values(?,?,?)";
sql = String.format(sql, tableConfig.getTable(), tableConfig.getKeyColumn(), tableConfig.getTypeColumn(), tableConfig.getSeqColumn());
int result = this.jdbcTemplate.update(sql, sequencesUnused.getKey(), sequencesUnused.getType(), sequencesUnused.getSeq());
return result != 0;
}
@Override @Override
public boolean saveBatch(List<SequencesUnused> sequencesUnusedList) { public boolean saveBatch(List<SequencesUnused> sequencesUnusedList) {
String sql = "insert into `%s_ununsed`(`%s`,`%s`,`%s`) values(?,?,?)"; String sql = "insert into `%s_ununsed`(`%s`,`%s`,`%s`) values(?,?,?)";

View File

@@ -1,8 +1,8 @@
package com.cdhncy.seq.generator; package com.yanghuanglin.seq.generator;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
import com.cdhncy.seq.po.SequencesUnlock; import com.yanghuanglin.seq.po.SequencesUnlock;
import com.cdhncy.seq.po.SequencesUnused; import com.yanghuanglin.seq.po.SequencesUnused;
import java.util.Date; import java.util.Date;
@@ -50,6 +50,16 @@ public interface Generator {
*/ */
String generate(String key, String type, Integer minLength); String generate(String key, String type, Integer minLength);
/**
* {@link #generate(String, String)}得到的序号对象格式化为补零后的序号字符串实际上只会用到{@link Sequences#getSeq()}属性
*
* @param sequences 生成的序号对象
* @param minLength 序号数字最小长度
* @param pattern 格式
* @return 格式化后的字符串
*/
String format(Sequences sequences, Integer minLength, String pattern);
/** /**
* 将生成的序号对象格式化为指定格式 * 将生成的序号对象格式化为指定格式
* <p/> * <p/>
@@ -111,4 +121,11 @@ public interface Generator {
* @param end 结束时间 * @param end 结束时间
*/ */
void release(Date begin, Date end); void release(Date begin, Date end);
/**
* 释放指定序号一般用于业务对象删除后对应序号需要回收使用时
*
* @param sequences 需要释放的序号一般是一个通过{@link Sequences#setKey(String)}{@link Sequences#setType(String)}{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象
*/
void release(Sequences sequences);
} }

View File

@@ -1,23 +1,26 @@
package com.cdhncy.seq.generator.impl; package com.yanghuanglin.seq.generator.impl;
import com.cdhncy.seq.config.GeneratorConfig; import com.yanghuanglin.seq.config.GeneratorConfig;
import com.cdhncy.seq.dao.SequencesDao; import com.yanghuanglin.seq.dao.SequencesDao;
import com.cdhncy.seq.dao.SequencesUnusedDao; import com.yanghuanglin.seq.dao.SequencesUnlockDao;
import com.cdhncy.seq.dao.SequencesUnlockDao; import com.yanghuanglin.seq.dao.SequencesUnusedDao;
import com.cdhncy.seq.dao.impl.SequencesDaoImpl; import com.yanghuanglin.seq.dao.impl.SequencesDaoImpl;
import com.cdhncy.seq.dao.impl.SequencesUnusedDaoImpl; import com.yanghuanglin.seq.dao.impl.SequencesUnlockDaoImpl;
import com.cdhncy.seq.dao.impl.SequencesUnlockDaoImpl; import com.yanghuanglin.seq.dao.impl.SequencesUnusedDaoImpl;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.generator.Generator;
import com.cdhncy.seq.po.SequencesUnused; import com.yanghuanglin.seq.po.Sequences;
import com.cdhncy.seq.po.SequencesUnlock; import com.yanghuanglin.seq.po.SequencesUnlock;
import com.cdhncy.seq.generator.Generator; import com.yanghuanglin.seq.po.SequencesUnused;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.support.JdbcTransactionManager; import org.springframework.jdbc.support.JdbcTransactionManager;
import org.springframework.transaction.support.TransactionTemplate; import org.springframework.transaction.support.TransactionTemplate;
import javax.sql.DataSource; import javax.sql.DataSource;
import java.util.*; import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
public class SequencesGenerator implements Generator { public class SequencesGenerator implements Generator {
private final TransactionTemplate transactionTemplate; private final TransactionTemplate transactionTemplate;
@@ -129,6 +132,11 @@ public class SequencesGenerator implements Generator {
return sequences.format(minLength); return sequences.format(minLength);
} }
@Override
public String format(Sequences sequences, Integer minLength, String pattern) {
return format(sequences.getSeq(), minLength, pattern);
}
@Override @Override
public String format(Long seq, Integer minLength, String pattern) { public String format(Long seq, Integer minLength, String pattern) {
return format(seq, null, minLength, pattern); return format(seq, null, minLength, pattern);
@@ -185,4 +193,10 @@ public class SequencesGenerator implements Generator {
//删除指定时间段内使用中表的数据 //删除指定时间段内使用中表的数据
sequencesUnlockDao.deleteByDate(begin, end); sequencesUnlockDao.deleteByDate(begin, end);
} }
@Override
public void release(Sequences sequences) {
sequencesUnlockDao.delete(new SequencesUnlock(sequences));
sequencesUnusedDao.save(new SequencesUnused(sequences));
}
} }

View File

@@ -1,4 +1,4 @@
package com.cdhncy.seq.po; package com.yanghuanglin.seq.po;
/** /**
@@ -35,6 +35,12 @@ public class Sequences {
this.type = type; this.type = type;
} }
public Sequences(String key, String type, Long seq) {
this.key = key;
this.type = type;
this.seq = seq;
}
public Sequences(SequencesUnused sequencesUnused) { public Sequences(SequencesUnused sequencesUnused) {
this.key = sequencesUnused.getKey(); this.key = sequencesUnused.getKey();
this.type = sequencesUnused.getType(); this.type = sequencesUnused.getType();

View File

@@ -1,4 +1,4 @@
package com.cdhncy.seq.po; package com.yanghuanglin.seq.po;
import java.util.Date; import java.util.Date;

View File

@@ -1,4 +1,4 @@
package com.cdhncy.seq.po; package com.yanghuanglin.seq.po;
/** /**

View File

@@ -1,8 +1,8 @@
import com.cdhncy.seq.config.GeneratorConfig; import com.yanghuanglin.seq.config.GeneratorConfig;
import com.cdhncy.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.cdhncy.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
import com.cdhncy.seq.generator.Generator; import com.yanghuanglin.seq.generator.Generator;
import com.cdhncy.seq.generator.impl.SequencesGenerator; import com.yanghuanglin.seq.generator.impl.SequencesGenerator;
import com.mysql.cj.jdbc.MysqlDataSource; import com.mysql.cj.jdbc.MysqlDataSource;
import org.junit.Test; import org.junit.Test;