分布式表 Sharded Cluster（分片集群）

### 说明

多个 shard，每个 shard 只有 1 个 replica

一个节点存储空间不足时候转为集群 这个节点不再添加数据 
另一个节点添加新数据 之后添加Distributed表

#### docker compose
```
services:
  my-ch-tron-main1:
    image: clickhouse/clickhouse-server:25.4
    container_name: my-ch-tron-main1
    hostname: clickhouse1
    restart: always
    ports:
      - 9003:9000
      - 8123:8123
    environment:
      REPLICA_ID: node1
      CLICKHOUSE_PASSWORD: 123456
    volumes:
      - ./cluster.xml:/etc/clickhouse-server/conf.d/cluster.xml:ro
      - ./ch-data1:/var/lib/clickhouse
      - ./ch-logs1:/var/log/clickhouse-server
    networks:
      - ch_net

my-ch-tron-main2:
    image: clickhouse/clickhouse-server:25.4
    container_name: my-ch-tron-main2
    hostname: clickhouse2
    restart: always
    ports:
      - 9004:9000
      - 8124:8123
    environment:
      REPLICA_ID: node2
      CLICKHOUSE_PASSWORD: 123456
    volumes:
      - ./cluster.xml:/etc/clickhouse-server/conf.d/cluster.xml:ro
      - ./ch-data2:/var/lib/clickhouse
      - ./ch-logs2:/var/log/clickhouse-server
    networks:
      - ch_net

networks:
  ch_net:
    external: true
```

#### cluster.xml
```
<clickhouse>
	<zookeeper>
		<node>
			<host>keeper1</host>
			<port>9181</port>
		</node>
	</zookeeper>
	<remote_servers>
		<my_cluster>
			<shard>
				<replica>
					<host>clickhouse1</host>
					<port>9000</port>
					<user>default</user>
					<password>123456</password>
				</replica>
			</shard>
			<shard>
				<replica>
					<host>clickhouse2</host>
					<port>9000</port>
					<user>default</user>
					<password>123456</password>
				</replica>
			</shard>
		</my_cluster>
	</remote_servers>
	<macros>
		<cluster>my_cluster</cluster>
		<replica from_env="REPLICA_ID"/>
	</macros>
</clickhouse>
```

#### 创建表
```
CREATE TABLE tron (
  txType UInt8,
  fromOrTo UInt8,
  blockNum UInt32,
  blockIndex UInt32,
  contract String,
  address String,
  address2 String,
  value Decimal128(0),
  txIndex UInt32,
  note String,
  txTime DateTime('Asia/Shanghai'),
  txid FixedString(64),
  txState Int8,
  balance Decimal128(0)
)
ENGINE = MergeTree()
ORDER BY (address, txTime)
PARTITION BY intDiv(blockNum, 1000000)
```
#### 创建分布式表

```
CREATE TABLE tron_distributed
AS tron
ENGINE = Distributed(
    my_cluster,
    default,
    tron,
    rand()
);
```