## 多数据库
可能是BeetlSQL最不好理解的部分，然而，应该还是比其他DAO工具更容易实现和理解
```java
/**
* <ui>
* <li>
* 演示多数据源操作中的ConditionalSQLManager，按照条件决定使用哪个SQLManager
* ConditionalSQLManager.decide方法决定使用哪个SQLManager，
* decide默认会读取目标对象的TargetSQLManager注解来决定，SQLManager的有些api参数没有目标对象，则使用默认SQLManager
* </li>
* <li>
* 演示user分表操作，动态表名实现分表
* </li>
* <li>
* 演示user分库操作，根据条件决定数据访问哪个数据库，使用了{@link ConditionalConnectionSource}
* </li>
* </ui>
*
*
* 注意：分库分表最好使用中间件
* @author xiandafu
*/
public class S6MoreDatabase {
public S6MoreDatabase() {
}
public static void main(String[] args) throws Exception {
S6MoreDatabase moreSource = new S6MoreDatabase();
moreSource.conditional();
moreSource.masterSlave();
moreSource.multipleTables();
moreSource.multipleDataBaseAndTables();
}
/**
* 多数据源协作
*/
public void conditional() {
SQLManager a = SampleHelper.init();
SQLManager b = SampleHelper.init();
Map<String, SQLManager> map = new HashMap<>();
map.put("a", a);
map.put("b", b);
SQLManager sqlManager = new ConditionalSQLManager(a, map);
//不同实体，用不同sqlManager操作，存入不同的数据库
UserData user = new UserData();
user.setName("hello");
user.setDepartmentId(2);
sqlManager.insert(user);
DepartmentData dept = new DepartmentData();
dept.setName("dept");
sqlManager.insert(dept);
}
/**
* 普通一主多从
*/
public void masterSlave(){
//为了简单起见，主从库都走同一个数据库
DataSource master = SampleHelper.mysqlDatasource();
DataSource slave1 = SampleHelper.mysqlDatasource();
DataSource slave2 = SampleHelper.mysqlDatasource();
ConnectionSource source = ConnectionSourceHelper.getMasterSlave(master,new DataSource[]{slave1,slave2});
SQLManagerBuilder builder = new SQLManagerBuilder(source);
builder.setNc(new UnderlinedNameConversion());
builder.setInters(new Interceptor[]{new DebugInterceptor()});
builder.setDbStyle(new MySqlStyle());
SQLManager sqlManager = builder.build();
//更新操作走主库
UserData user = new UserData();
user.setName("a");
user.setDepartmentId(1);
sqlManager.insert(user);
//查询走从库
sqlManager.unique(UserData.class,1);
}
/**
* 单库分表操作,user对象的{@code @Table}注解是逻辑表达式
* <pre>{@code
* @Table(name="${toTable('user',id)}"
* public class User{
*
* }
* }</pre>
* toTable方法是一个自定义注册的beetl方法，在运行的时候会根据id换算出真实表
*
* 对于beetlsql所有内置方法，都可以自动分表，但你自己的sql，也要类似使用
* {@code ${toTable('user',id)}}
* @see TableChoice
*/
public void multipleTables(){
SQLManager sqlManager = getSQLManager4MultipleTables();
//使用user表
sqlManager.deleteById(MyUser.class,199);
MyUser user = new MyUser();
user.setName("abc");
user.setId(199);
sqlManager.insert(user);
//使用user_1表. 为了简单起见，分表逻辑返回的目标表还是user表
MyUser user2 = new MyUser();
user2.setName("abc");
user2.setId(1500);
sqlManager.insert(user2);
}
/**
* 分库分布表操作，同{@link #multipleTables()} 方法，但增加如果id超过一定限额，走另外一个数据库
* 核心还是需要定义一个分库分表逻辑
* @see TableAndDataBaseChoice
*/
public void multipleDataBaseAndTables(){
SQLManager sqlManager = getSQLManager4MultipleDatBase();
sqlManager.deleteById(MyUser.class,199);
MyUser user = new MyUser();
user.setName("abc");
user.setId(199);
sqlManager.insert(user);
//这条记录使用第二个库的user表
sqlManager.deleteById(MyUser.class,2900);
MyUser user2 = new MyUser();
user2.setName("abc");
user2.setId(2900);
sqlManager.insert(user2);
}
protected SQLManager getSQLManager4MultipleTables(){
SQLManager sqlManager = SampleHelper.getSqlManager();
//告诉sqlManager遇到USER_TABLE这个不存在的表不慌，他是个虚表，真实表是user
sqlManager.addVirtualTable("user",USER_TABLE);
BeetlTemplateEngine templateEngine = (BeetlTemplateEngine)sqlManager.getSqlTemplateEngine();
// 注册一个方法来实现映射到多表的逻辑
templateEngine.getBeetl().getGroupTemplate().registerFunction("toTable", new Function(){
@Override
public Object call(Object[] paras, Context ctx) {
String tableName = (String)paras[0];
Integer id = (Integer)paras[1];
//使用分表逻辑
TableChoice tableChoice = new TableChoice();
return tableChoice.getTableName(tableName,id);
}
});
return sqlManager;
}
/**
* 分表选择逻辑
*/
public static class TableChoice{
public String getTableName(String tableName,Integer id){
if(id<1000){
return tableName;
}else{
//根据需要返回另外一个表，比如tableName+"_1"
return tableName;
// return tableName+"_1";
}
}
}
/**
* 分库选择逻辑，用户自由实现分表分库逻辑，
*/
public static class TableAndDataBaseChoice{
public String getTableName(ExecuteContext executeContext,String tableName,Integer id){
if(id<1000){
return tableName;
}else if(id<2000){
return tableName+"_1";
}else{
//如果继续大，设置一个标记，进入另外一个数据库cs2库的user表
executeContext.setContextPara(FLAG,"cs2");
if(id<3000){
return tableName;
}else{
return tableName+"_1";
}
}
}
}
private static final String FLAG ="connectionSource";
protected SQLManager getSQLManager4MultipleDatBase(){
//为了测试方便，假设指向同一个数据库
DataSource db1 = SampleHelper.mysqlDatasource();
ConnectionSource cs1 = ConnectionSourceHelper.getSingle(db1);
DataSource db2 = SampleHelper.mysqlDatasource();
ConnectionSource cs2 = ConnectionSourceHelper.getSingle(db2);
Map<String,ConnectionSource> datas = new HashMap<>();
datas.put("cs1",cs1);
datas.put("cs2",cs2);
// 配置策略
ConditionalConnectionSource.Policy policy = new ConditionalConnectionSource.Policy() {
@Override
public String getConnectionSourceName(ExecuteContext ctx, boolean isUpdate) {
String name = (String)ctx.getContextPara(FLAG);
if(name!=null){
return name;
}else{
// 如果没有设置，则返回一个默认库
return "cs1";
}
}
@Override
public String getMasterName() {
return "cs1";
}
};
ConditionalConnectionSource ds = new ConditionalConnectionSource(policy,datas);
// 初始化sqlManager，使用ConditionalConnectionSource
SQLManagerBuilder builder = new SQLManagerBuilder(ds);
builder.setNc(new UnderlinedNameConversion());
builder.setInters(new Interceptor[]{new DebugInterceptor()});
builder.setDbStyle(new MySqlStyle());
SQLManager sqlManager = builder.build();
// 申明一个虚表 "${toTable('user',id)}"，实际上是user表
sqlManager.addVirtualTable("user",USER_TABLE);
BeetlTemplateEngine templateEngine = (BeetlTemplateEngine)sqlManager.getSqlTemplateEngine();
// 注册一个方法来实现映射到多表的逻辑
templateEngine.getBeetl().getGroupTemplate().registerFunction("toTable", new Function(){
@Override
public Object call(Object[] paras, Context ctx) {
String tableName = (String)paras[0];
Integer id = (Integer)paras[1];
ExecuteContext executeContext = (ExecuteContext)ctx.getGlobal(ExecuteContext.NAME);
//使用分库逻辑
TableAndDataBaseChoice choice = new TableAndDataBaseChoice();
return choice.getTableName(executeContext,tableName,id);
}
});
return sqlManager;
}
/**
* 用户数据使用"a" sqlmanager
*/
@Data
@Table(name = "user")
@TargetSQLManager("a")
public static class UserData {
@Auto
private Integer id;
private String name;
private Integer departmentId;
}
/**
* 部门数据使用"b" sqlmanager
*/
@Data
@Table(name = "department")
@TargetSQLManager("b")
public static class DepartmentData {
@Auto
private Integer id;
private String name;
}
static final String USER_TABLE="${toTable('user',id)}";
@Data
@Table(name = USER_TABLE)
public static class MyUser {
@AssignID
private Integer id;
private String name;
}
}
```
- BeetlSQL 3 指南
- 数据访问框架
- 适合用户
- 编译源码
- 直接看代码
- 闲大赋介绍
- BeetlSQL3 特点
- 数据库访问工具的痛点
- BeetlSQL3 例子
- 基础例子
- 结果集映射
- 翻页查询
- 演示like，batchUpdate,in 操作
- 自动fetch
- 多数据库
- 代码生成框架
- 安装BeetlSQL
- 直接安装
- 框架集成
- 编译源码
- 快速开始
- 环境准备
- 环境搭建
- 使用BeetlSQL
- 按照主键查寻
- 更新
- 按照模板查询
- 执行SQL
- 执行模板SQL
- 使用Query
- 使用Mapper
- 使用模板文件
- SQLManager
- 内置语句
- 内置查询API
- template查询
- 更新操作
- 执行SQL
- 执行模板SQL
- 把SQL放到文件里
- 翻页查询
- SQLResult
- Stream查询
- 存储过程调用
- NameConversion（重要）
- DBStyle
- Inerceptor
- SQLManagerExtend
- 强制使用数据源
- Mapper
- 实现Mapper
- @Sql
- @Update @BatchUpdate
- @Template
- 参数名称
- 参数返回值
- 执行SQL文件
- 翻页查询
- @SqlProvider
- @SpringData
- @SubQuery
- @InheritMapper
- @Call
- StreamData
- Default Method
- 定义自己的BaseMapper
- 限制Java代码中SQL长度
- 数据模型
- POJO
- 不严格的POJO
- 交集（重要)
- @Table 注解
- @Column 注解
- 主键
- RowMapper
- ResultSetMapper
- Json配置映射
- Json自动映射
- XML支持
- 自动Fetch
- AttributeConvert
- BeanConvert
- 枚举
- 混合模型
- Map模型
- 动态模型
- 模型其他注解
- 安全扩展注解
- BeetlSql 单表查询工具Query
- Query使用方式和风格介绍
- Query主要操作简介
- 查询器获取
- SELECT简单的条件查询
- 复杂的条件查询
- 查询字段智能处理
- 健壮的变量
- 自定义实现
- INSERT操作
- UPDATE操作
- DELETE操作
- single查询和unique
- COUNT查询
- GROUP分组查询和Having子句
- 分页查询
- ORDER BY 排序
- page分页查询
- 方法调用顺序
- Markdown文件
- Beetl 入门
- 定界符号
- 变量
- 算数表达式
- 逻辑表达式
- 控制语句
- 访问变量属性
- 判断对象非空（重要）
- 调用方法
- 自定义方法
- 内置方法
- 标签功能
- 附录
- Idea 插件
- 代码生成
- 多库使用
- 业务主从库
- 主从库延迟问题
- 多个业务库
- 合并多个业务库 1
- 合并多个业务库 2
- 单表多租户
- 每个租户一个表
- 多库多租户
- 使用ShardingSphere
- Saga（试验）
- 关于Saga的一些认识
- 关于隔离性
- BeetlSQL Saga
- SagaMapper
- Saga 多库事务实现
- Saga 微服务 实现
- 配置 Saga Server
- Swagger
- BeetlSQL 性能
- 测试方法
- 最新
- 2021-11-21
- 2020-9-28
- Spring 快速开始
- 环境准备
- 环境搭建
- SpringBoot 快速开始
- 环境准备
- 环境搭建
- 扩展BeetlSQL3
- 完整配置
- BaseMapper定制
- 代码生成
- SQLExecutor定制
- 第三方
- MetadataManager
- JFinal集成
- ExecuteContext
- 参考ACT
- 数据库表到Java对象
- Solon
- NameConversion
- ViewType
- RowMapper
- ResultSetMapper
- AttributeConvert
- BeanConvert
- Fetch
- 代码生成
- 扩展BeetlSQL3
- BaseMapper定制
- SQLExecutor定制
- MetadataManager
- ExecuteContext
- 数据库表到Java对象
- NameConversion
- ViewType
- RowMapper
- ResultSetMapper
- AttributeConvert
- BeanConvert
- Fetch
- 代码生成
- BeetlSQL 多数据库支持
- 多库之间的不同
- 跨库支持实现
- DBStyle
- MySqlStyle 例子
- H2Style例子
- ClickHouseStyle例子
- HBaseStyle例子
- DruidStyle例子
- MetadataManager
- BeanProcessor
- 与BeetlSQL2的区别
- 使用区别