shareding-jdbc史上最简单的示例

缺乏、安全感 2022-05-25 01:30 390阅读 0赞

<table> 
 <tbody> 
 <tr> 
 <td>shared-jdbc简介Sharding-JDBC是当当应用框架ddframe中，从关系型数据库模块dd-rdb中分离出来的数据库水平分片框架，实现透明化数据库分库分表访问。Sharding-JDBC是继dubbox和elastic-job之后，ddframe系列开源的第3个项目。Sharding-JDBC直接封装JDBC协议，可以理解为增强版的JDBC驱动，旧代码迁移成本几乎为零。Sharding-JDBC定位为轻量级java框架，使用客户端直连数据库，以jar包形式提供服务，无proxy代理层，无需额外部署，无其他依赖，DBA也无需改变原有的运维方式。 1.导入依赖&lt;dependencies&gt;&lt;dependency&gt;&lt;groupId&gt;junit&lt;/groupId&gt;&lt;artifactId&gt;junit&lt;/artifactId&gt;&lt;version&gt;4.0&lt;/version&gt;&lt;scope&gt;test&lt;/scope&gt;&lt;/dependency&gt;&nbsp;&lt;dependency&gt;&lt;groupId&gt;io.shardingjdbc&lt;/groupId&gt;&lt;artifactId&gt;sharding-jdbc-core&lt;/artifactId&gt;&lt;version&gt;2.0.0&lt;/version&gt;&lt;/dependency&gt;&nbsp;&lt;dependency&gt;&lt;groupId&gt;com.alibaba&lt;/groupId&gt;&lt;artifactId&gt;druid&lt;/artifactId&gt;&lt;version&gt;1.0.13&lt;/version&gt;&lt;/dependency&gt;&lt;dependency&gt;&lt;groupId&gt;mysql&lt;/groupId&gt;&lt;artifactId&gt;mysql-connector-java&lt;/artifactId&gt;&lt;version&gt;5.1.28&lt;/version&gt;&lt;/dependency&gt;&lt;/dependencies&gt;2.表的创建语句CREATE TABLE `t_order_x` (&nbsp;&nbsp;`order_id` int(11) NOT NULL,&nbsp;&nbsp;`user_id` int(11) NOT NULL,&nbsp;&nbsp;PRIMARY KEY (`order_id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8&nbsp;3.获取数据源package&nbsp;com.irisian.sharedjdbc;import&nbsp;java.sql.SQLException;import&nbsp;java.util.HashMap;import&nbsp;java.util.Map;import&nbsp;java.util.Properties;import&nbsp;java.util.concurrent.ConcurrentHashMap;import&nbsp;javax.sql.DataSource;import&nbsp;com.alibaba.druid.pool.DruidDataSource;import&nbsp;io.shardingjdbc.core.api.ShardingDataSourceFactory;import&nbsp;io.shardingjdbc.core.api.config.ShardingRuleConfiguration;import&nbsp;io.shardingjdbc.core.api.config.TableRuleConfiguration;import&nbsp;io.shardingjdbc.core.api.config.strategy.InlineShardingStrategyConfiguration;public&nbsp;class&nbsp;DateSourceUtils { public&nbsp;static&nbsp;DataSource getDataSource() throws&nbsp;SQLException { &nbsp;// 配置真实数据源Map&lt;String, DataSource&gt; dataSourceMap&nbsp;= new&nbsp;HashMap&lt;&gt;();&nbsp;// 配置第一个数据源DruidDataSource dataSource1&nbsp;= new&nbsp;DruidDataSource();dataSource1.setDriverClassName("com.mysql.jdbc.Driver");dataSource1.setUrl("jdbc:mysql://localhost:3306/db0");dataSource1.setUsername("root");dataSource1.setPassword("123456");// 将数据库放入到数据库map集合中dataSourceMap.put("db0", dataSource1);&nbsp;// 配置第二个数据源DruidDataSource dataSource2&nbsp;= new&nbsp;DruidDataSource();dataSource2.setDriverClassName("com.mysql.jdbc.Driver");dataSource2.setUrl("jdbc:mysql://localhost:3306/db1");dataSource2.setUsername("root");dataSource2.setPassword("123456");// 将数据库放入到map集合中dataSourceMap.put("db1", dataSource2);&nbsp;// 配置Order表规则TableRuleConfiguration orderTableRuleConfig&nbsp;= new&nbsp;TableRuleConfiguration();orderTableRuleConfig.setLogicTable("t_order");//下面这两种是等价的，表示在两个库均匀分布/**&nbsp;* db0&nbsp;&nbsp;├── t_order_0 &nbsp;&nbsp;└── t_order_1 db1&nbsp;&nbsp;├── t_order_0 &nbsp;&nbsp;└── t_order_1&nbsp;*/orderTableRuleConfig.setActualDataNodes("db0.t_order_0, db0.t_order_1, db1.t_order_0, db1.t_order_1");//orderTableRuleConfig.setActualDataNodes("db${0..1}.t_order_${0..1}");&nbsp;// 配置分库策略 orderTableRuleConfig.setDatabaseShardingStrategyConfig(new&nbsp;InlineShardingStrategyConfiguration("user_id", "db${user_id % 2}"));&nbsp;// 配置分表策略orderTableRuleConfig.setTableShardingStrategyConfig(new&nbsp;InlineShardingStrategyConfiguration("order_id", "t_order_${order_id % 2}"));&nbsp;// 配置分片规则ShardingRuleConfiguration shardingRuleConfig&nbsp;= new&nbsp;ShardingRuleConfiguration();shardingRuleConfig.getTableRuleConfigs().add(orderTableRuleConfig);&nbsp;// 获取数据源对象DataSource dataSource&nbsp;= ShardingDataSourceFactory.createDataSource(dataSourceMap, shardingRuleConfig,new&nbsp;ConcurrentHashMap(), new&nbsp;Properties());return&nbsp;dataSource;&nbsp;}&nbsp;}4.操作数据库package&nbsp;com.irisian.sharedjdbc;import&nbsp;java.sql.Connection;import&nbsp;java.sql.PreparedStatement;import&nbsp;java.sql.SQLException;import&nbsp;javax.sql.DataSource;public&nbsp;class&nbsp;Test { public&nbsp;static&nbsp;void&nbsp;main(String[] args) throws&nbsp;SQLException { DataSource dataSource&nbsp;= DateSourceUtils.getDataSource();Connection conn&nbsp;= dataSource.getConnection();String sql="insert into t_order(order_id,user_id) values(?,?)";PreparedStatement prep&nbsp;= conn.prepareStatement(sql);prep.setInt(1, 3);prep.setInt(2, 1);prep.execute();}}</td> 
 </tr> 
 </tbody> 
</table>