springboot~shardingsphere在非spring框架中的使用

shardingsphere已经很方便的被springboot集成了，你只要引入sharding-jdbc-spring-boot-starter这个包就可以了，而如果是原生java的话，你就需要自己去实现了，主要是重新定义数据源，定义规则等问题，本文主要介绍原生环境下的shardingsphere的使用。
依赖引用

1. <dependencies>
2.         
3.         <dependency>
4.             <groupId>mysql</groupId>
5.             <artifactId>mysql-connector-java</artifactId>
6.             <version>8.0.30</version>
7.         </dependency>
9.         
10.         <dependency>
11.             <groupId>com.zaxxer</groupId>
12.             <artifactId>HikariCP</artifactId>
13.             <version>4.0.3</version>
14.         </dependency>
16.         
17.         <dependency>
18.             <groupId>org.apache.shardingsphere</groupId>
19.             <artifactId>sharding-jdbc-core</artifactId>
20.             <version>4.1.1</version>
21.         </dependency>
23.         
24.         <dependency>
25.             <groupId>org.hibernate</groupId>
26.             <artifactId>hibernate-core</artifactId>
27.             <version>5.4.15.Final</version>
28.         </dependency>
30.         
31.         <dependency>
32.             <groupId>org.projectlombok</groupId>
33.             <artifactId>lombok</artifactId>
34.             <version>1.18.12</version>
35.         </dependency>
37.         <dependency>
38.             <groupId>org.slf4j</groupId>
39.             <artifactId>slf4j-log4j12</artifactId>
40.             <version>1.7.25</version>
41.         </dependency>
42.     </dependencies>

复制代码

建立DataSource数据源

• 添加了数据源，确定了mysql数据库，支持同时设置多个数据源
  
• 定义了分库分表的规则
  

1.   public static DataSource createDataSource() throws SQLException {
2.     // 配置真实数据源
3.     Map<String, DataSource> dataSourceMap = new HashMap<>();
4.     // 配置第一个 MySQL 数据源
5.     HikariDataSource ds0 = new HikariDataSource();
6.     ds0.setDriverClassName("com.mysql.jdbc.Driver");
7.     ds0.setJdbcUrl("jdbc:mysql://192.168.xx.xx:3306/sharding0");
8.     ds0.setUsername("root");
9.     ds0.setPassword("123456");
10.     dataSourceMap.put("ds0", ds0);
12.     // 配置分片规则
13.     TableRuleConfiguration tableRuleConfig = new TableRuleConfiguration("t_order", "ds0.t_order_${0..2}");
14.     ShardingStrategyConfiguration shardingStrategyConfiguration = new StandardShardingStrategyConfiguration("order_id", new ModuloShardingAlgorithm());
15.     tableRuleConfig.setTableShardingStrategyConfig(shardingStrategyConfiguration);
17.     ShardingRuleConfiguration shardingRuleConfig = new ShardingRuleConfiguration();
18.     shardingRuleConfig.getTableRuleConfigs().add(tableRuleConfig);
20.     // 创建 ShardingSphere 数据源
21.     return ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig, new Properties());
22. }

复制代码

建立分表规则

1. /**
2. * 分表算法
3. */
4. public class ModuloShardingAlgorithm implements PreciseShardingAlgorithm<Long> {
6.     @Override
7.     public String doSharding(Collection<String> availableTargetNames, PreciseShardingValue<Long> shardingValue) {
8.         for (String each : availableTargetNames) {
9.             if (each.endsWith(String.valueOf(shardingValue.getValue() % 2))) {
10.                 return each;
11.             }
12.         }
13.         throw new UnsupportedOperationException();
14.     }
15. }

复制代码

源生SQL方式读取数据

1. static void select() throws SQLException {
2.     // 创建数据源
3.     DataSource dataSource = createDataSource();
5.     // 执行SQL
6.     try (Connection conn = dataSource.getConnection()) {
7.         String sql = "SELECT * FROM t_order WHERE order_id = ?";
8.         try (PreparedStatement preparedStatement = conn.prepareStatement(sql)) {
9.             preparedStatement.setLong(1, 11L);
10.             try (ResultSet resultSet = preparedStatement.executeQuery()) {
11.                 while (resultSet.next()) {
12.                     System.out.println(resultSet.getString("order_id"));
13.                 }
14.             }
15.         }
16.     }
17. }

复制代码

Hibernate方式，写入，读取数据

定义实体

1. @Entity
2. @Data
3. @Table(name = "t_order")
4. @NamedQueries({
5.         @NamedQuery(
6.                 name = "findById",
7.                 query = "FROM Order t WHERE t.orderId = :orderId"
8.         )
9. })
10. public class Order {
11.     @Id
12.     @Column(name = "order_id", nullable = false)
13.     private Long orderId;
14.     @Column(name = "user_id", nullable = false)
15.     private Long userId;
16.     @Column(name = "amount", nullable = false)
17.     private Double amount;
18. }

复制代码

定义数据仓库

1. public class OrderRepository {
2.     // 创建EntityManagerFactory
3.     EntityManagerFactory entityManagerFactory;
5.     // 创建EntityManager
6.     EntityManager entityManager;
8.     public OrderRepository() throws SQLException {
9.         this.entityManagerFactory = Persistence.createEntityManagerFactory("lindDb", getProperties(Main.createDataSource()));
10.         this.entityManager = entityManagerFactory.createEntityManager();
11.     }
13.     private static Map<String, Object> getProperties(DataSource dataSource) {
14.         Map<String, Object> properties = new HashMap<>();
15.         properties.put("javax.persistence.nonJtaDataSource", dataSource);
16.         return properties;
17.     }
19.     public List<Order> findById(Long id) {
20.         return entityManager.createQuery("findById", Order.class).setParameter("orderId", id).getResultList();
21.     }
23.     public void save(Order order) {
24.         entityManager.getTransaction().begin();
25.         entityManager.persist(order);
26.         entityManager.getTransaction().commit();
27.         entityManager.close();
28.         entityManagerFactory.close();
29.     }
30. }

复制代码

定义添加逻辑及测试

1. static void HihernateInsert() throws SQLException {
2.     OrderRepository orderRepository = new OrderRepository();
3.     Order order = new Order();
4.     order.setAmount(100d);
5.     order.setOrderId(11L);
6.     order.setUserId(6L);
7.     orderRepository.save(order);
8. }

复制代码

根据分表的规则，这条数据会被写到t_order_1这张数据表里。

注意：当采用分表规则之后，如果你的记录主键没有按着规则存储，是无法获取到时数据的，如order_id为1的记录被存储到了t_order_0里，那这条数据将无法被找到。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！