shardingsphere实例应用

shardingSphere的精确分片和复杂分片的应用。

订单表实际表DDL如下：

CREATE TABLE `t_order_06` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`user_id` bigint(20) DEFAULT NULL,`order_id` bigint(20) DEFAULT NULL,`regdate` timestamp NULL DEFAULT NULL,PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=15 DEFAULT CHARSET=utf8;

Maven依赖

<dependency><groupId>org.apache.shardingsphere</groupId><artifactId>sharding-jdbc-core</artifactId><version>4.0.0-RC1</version>
</dependency>

自定义单一字段精确分区算法

public class MyPreciseShardingAlgorithm implements PreciseShardingAlgorithm<java.util.Date> {@Overridepublic String doSharding(Collection<String> collection, PreciseShardingValue<Date> preciseShardingValue) {String logicTableName = preciseShardingValue.getLogicTableName();Date date = preciseShardingValue.getValue();List<String> shardingSuffix = new ArrayList<>();//获取日期时间所在的月份String str = DateFormatUtil.formatMonth(date);//添加记录所在分表表名集合shardingSuffix.add(logicTableName + "_" + str);return null;}
}

自定义时间字段复杂分区算法

@Slf4j
public class MyComplexShardingAlgorithm implements ComplexKeysShardingAlgorithm {@Overridepublic Collection<String> doSharding(Collection collection, ComplexKeysShardingValue complexKeysShardingValue) {log.info("自定义按照日期进行分表");List<String> shardingSuffix = new ArrayList<>();//获取分表字段及字段值Map<String, Collection<Date>> map = complexKeysShardingValue.getColumnNameAndShardingValuesMap();//获取字段值Collection<Date> shardingValues = map.get("regdate");if (!CollectionUtils.isEmpty(shardingValues)) {for (Date date : shardingValues) {//获取日期时间所在的月份String str = DateFormatUtil.formatMonth(date);//添加记录所在分表表名集合shardingSuffix.add(complexKeysShardingValue.getLogicTableName() + "_" + str);}}return shardingSuffix;}
}

单库分表代码

@Slf4j
public class Demo {public static void main(String[] args) throws SQLException {Map<String, DataSource> dataSourceMap = new HashMap<>();DruidDataSource dataSource1 = new DruidDataSource();dataSource1.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource1.setUrl("jdbc:mysql://localhost:3306/spark?autoReconnect=true&useUnicode=true&characterEncoding" +"=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true");dataSource1.setUsername("root");dataSource1.setPassword("root");dataSourceMap.put("database0", dataSource1);//数据库表分库分表规则TableRuleConfiguration tableRuleConfiguration = new TableRuleConfiguration("t_order");//根据字段进行分库
//        tableRuleConfiguration.setDatabaseShardingStrategyConfig(new InlineShardingStrategyConfiguration("user_id",
//                "database${user_id % 2}"));//根据字段进行分表
//        tableRuleConfiguration.setTableShardingStrategyConfig(new InlineShardingStrategyConfiguration("order_id",
//                "t_order_${order_id % 2}"));//自定义复杂分表设置 MyComplexShardingAlgorithm自定义分表算法tableRuleConfiguration.setTableShardingStrategyConfig(new ComplexShardingStrategyConfiguration("regdate",new MyComplexShardingAlgorithm()));ShardingRuleConfiguration shardingRuleConfiguration = new ShardingRuleConfiguration();shardingRuleConfiguration.getTableRuleConfigs().add(tableRuleConfiguration);DataSource dataSource = ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfiguration,new Properties());String sql = "insert into t_order (user_id,order_id,regdate) values (?, ?, ?)";Date date = new Date(System.currentTimeMillis());Connection connection = dataSource.getConnection();PreparedStatement preparedStatement = connection.prepareStatement(sql);preparedStatement.setInt(1, 3);preparedStatement.setInt(2, 2);preparedStatement.setDate(3, date);preparedStatement.execute();}
}

shardingsphere实例应用相关推荐

ShardingSphere实践（1）——ShardingSphere介绍
目录一.分库分表 1. 为什么需要分库分表 (1)突破性能瓶颈 (2)提高可用性 2. 什么时候考虑分库分表 3. 如何分库分表 (1)水平拆分与垂直拆分 (2)水平分库分表策略 (3)分成多少库多 ...
ShardingSphere介绍
什么是 ShardingSphere https://shardingsphere.apache.org/document/current/cn/overview/ 介绍 Apache Shardin ...
ShardingSphere Mode 模式新起航：运行模式详解
在 5.0.0 GA 版本中,Apache ShardingSphere 新增了运行模式的概念,同时提供了 Memory/Standalone/Cluster 3 种配置方式.ShardingSphe ...
Sharding-JDBC 基础
Sharding-JDBC 是当当网开源的适用于微服务的分布式数据访问基础类库,完整的实现了分库分表,读写分离和分布式主键功能,并初步实现了柔性事务. 从 2016 年开源至今,在经历了整体架构的数次 ...
SpringBoot配置读写分离
SpringBoot配置读写分离 1 概述本文讲述了如何使用MyBatisPlus+ShardingSphereJDBC进行读写分离,以及利用MySQL进行一主一从的主从复制. 具体步骤包括: My ...
前端开发基础知识汇总
一.HTML 1.前言与常用标签浏览器内核备注 IE Trident IE.猎豹安全.360极速浏览器.百度浏览器 firefox Gecko 可惜这几年已经没落了,打开速度慢.升级频繁.猪一样 ...
Spring Cloud微服务系统架构的一些简单介绍和使用
Spring Cloud 目录特征云原生应用程序 Spring Cloud上下文:应用程序上下文服务引导应用程序上下文应用程序上下文层次结构改变Bootstrap的位置Properties ...
京东sdk调用实例_Apache ShardingSphere（Incubating）对接京东白条实战
作者张永伦,京东数科高级软件工程师,Apache ShardingSphere(Incubating) PPMC.长期从事分布式系统的高可用.高并发相关工作.热衷于网络IO.性能优化方面的技术挑战. ...
sharding-sphere按月动态分表
公司有个记录表,每天有几百万的数据,所以我决定按月把他分下表. 用spring整合的. 首先,sharding-sphere不支持自动创建表,所以我提前创建了两年的表,命名规则 logicTableN ...

shardingsphere实例应用

shardingsphere实例应用相关推荐

最新文章

热门文章