Luis Munoz
04/15/2020, 6:38 PMsqlQueryBuilder.append("id BIGINT AUTO_INCREMENT NOT NULL,");
sqlQueryBuilder.append("ts DATETIME(6) NOT NULL,");
sqlQueryBuilder.append("uuid VARBINARY(32) NOT NULL,");
sqlQueryBuilder.append("data JSON,");
sqlQueryBuilder.append("SHARD(id),");
sqlQueryBuilder.append("KEY(ts) USING CLUSTERED COLUMNSTORE)");
tapac
04/15/2020, 8:03 PMabstract class ShardedTable(tableName: String, val shard: String) : Table(tableName) {
override fun createStatement(): List<String> {
return super.createStatement().map { statement ->
if (statement.startsWith("CREATE TABLE "))
statement.removeSuffix(")") + "SHARD($shard))"
else statement
}
}
}
Luis Munoz
04/15/2020, 10:29 PM