创建表

功能介绍

通过on cluster语句在集群中创建clickhouse-example.properties中tableName参数值为表名的ReplicatedMerge表和Distributed表。

样例代码

private void createTable(String databaseName, String tableName, String clusterName) throws Exception {
	String createSql = "create table " + databaseName + "." + tableName + " on cluster " + clusterName
			+ " (name String, age UInt8, date Date)engine=ReplicatedMergeTree('/clickhouse/tables/{shard}/" + databaseName
			+ "." + tableName + "'," + "'{replica}') partition by toYYYYMM(date) order by age";
	String createDisSql = "create table " + databaseName + "." + tableName + "_all" + " on cluster " + clusterName + " as "
			+ databaseName + "." + tableName + " ENGINE = Distributed(default_cluster," + databaseName + "," + tableName + ", rand());";
	ArrayList<String> sqlList = new ArrayList<String>();
	sqlList.add(createSql);
	sqlList.add(createDisSql);
	util.exeSql(sqlList);
}