- Simple shardingsphere library
- Simple shardingsphere REST API server
mvn install// =================
// Yaml style
// =================
SynbagConfig synbagConfig = SynbagConfig.loadAndConfigSynbag("synbag-config.yml");
DataSource shardingDatasource = synbagConfig.getShardingDatasource();
Connection connection = shardingDatasource.getConnection();
connection.close();
// =================
// Code style
// =================
SynbagConfig synbagConfig = new SynbagConfig();
// DataSource
DataSource[] datasources = ..;
synbagConfig.setDataSources(datasources);
// Sharding table
Map<String, ShardingTable> shardingTables = new HashMap<String, ShardingTable>();
ShardingTable shardingTable = new ShardingTable();
shardingTable.setShardingColumn("userid");
shardingTable.setShardingMethod("crc32");
shardingTables.put("user", shardingTable);
synbagConfig.setShardingTables(shardingTables); // Add sharding policy
// Broadcast table
List<String> broadcastTables = new ArrayList<String>();
synbagConfig.setBroadcastTables(broadcastTables); // Add broadcast policy
// Initialize
synbagConfig.init();sample config file
dataSources:
- !!org.apache.commons.dbcp2.BasicDataSource
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/shard01?autoReconnect=true
username: shard01
password: shard01
maxTotal: 30
- !!org.apache.commons.dbcp2.BasicDataSource
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/shard02?autoReconnect=true
username: shard02
password: shard02
maxTotal: 30
shardingTables:
user:
realTableName: user
shardingColumn: userid
shardingMethod: crc32
user_log:
shardingColumn: userid
shardingMethod: crc32
broadcastTables: [config]Usage: <main class> [-c=<configFile>] [-p=<port>] [-r=<route>]
-c, --config-file=<configFile>
Config file
-p, --port=<port> API server port
-r, --route=<route> Route home
$ java -jar target/synbag-0.0.1.jar
## Query
$ curl -X POST --data-urlencode "query=select * from user" 127.0.0.1:5280/q
{"rowCount":2,"rows":[{"dttm":"2021-07-26 13:29:51.644552","name":"abcde-name0","userid":"abcde0"},{"dttm":"2021-07-26 13:29:51.647925","name":"abcde-name1","userid":"abcde1"}]}
## INSERT
$ curl -X POST -d '{type=INS, extra={value={ver=4,info=v.4}}}' 127.0.0.1:5280/t/config
## UPDATE
$ curl -X POST -d '{type=UPD, extra={value={info=v.5}, where={ver=4}}}' 127.0.0.1:5280/t/config
## DELETE
$ curl -X POST -d '{type=DEL, extra={where={ver=4}}}' 127.0.0.1:5280/t/config
## GET
$ curl -X POST -d '{type=GET, extra={where={userid=abcde51}}}' 127.0.0.1:5280/t/user
## GET ALL
$ curl -X POST -d '{type=GET}' 127.0.0.1:5280/t/user
## GET with extra options
$ curl -X POST -d '{type=GET, extra={orderBy="name desc"}}' 127.0.0.1:5280/t/user
$ curl -X POST -d '{type=GET, extra={orderBy="name desc", limit=10}}' 127.0.0.1:5280/t/user
$ curl -X POST -d '{type=GET, extra={orderBy="name desc", limit=10, offset=5}}' 127.0.0.1:5280/t/user
$ curl -X POST -d '{type=GET, extra={orderBy="name desc", clause="name like \"%abcde-name8%\""}}' 127.0.0.1:5280/t/userStill developping.. Enjoy.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent