Awesome
一个php实现的clickhouse tcp协议客户端 | php tcp client for clickhouse
- 支持流式写入 Support streaming writing
- 超高的性能，支持1000w/s的写入速度 Super high performance, Support 1000w/s writing speed
- tcp对服务器对服务器友好，压力小 tcp is server-friendly, with little pressure
- 零依赖 Zero dependence
安装 | install
composer require lizhichao/one-ck
php5.6 - php7.1不支持Decimal128，请使用0.1.x版本
php7.2 >=推荐使用0.2.x版本
clickhouse QQ交流群 970435787
支持的数据类型 | Supported types
- UInt8, UInt16, UInt32, UInt64, Int8, Int16, Int32, Int64
- Float32, Float64
- Decimal(P, S), Decimal32(S), Decimal64(S), Decimal128(S)
- String
- Nothing
- FixedString(N)
- UUID
- Date
- Datetime
- Datetime64
- Nullable(T)
- IPv4
- IPv6
- Array(T)
- SimpleAggregateFunction(F, T)
- Tuple(T)
- Int128,Int256,UInt128,UInt256,Decimal256(S)
- Bool
- JSON
- Enum (can use
LowCardinalityinstead)
Array of client options
It is also possible to create the client with configuration options:
use OneCk\Client;
$client = new Client(
'tcp://localhost:9000',
'username',
'password',
'database',
[
'connect_timeout' => 3,
'socket_timeout' => 30,
'tcp_nodelay' => true,
'persistent' => true,
]
);
The following options are available:
| Name | Type | Default | Description |
|---|---|---|---|
| connect_timeout | float | 3.0 | The number of seconds that the client waits for a connect to a ClickHouse server before throwing a CkException exception. |
| socket_timeout | float | 30.0 | The number of seconds that the client waits for a respond from a ClickHouse server before throwing a CkException exception. |
| tcp_nodelay | boolean | false | Whether the Nagle algorithm is disabled on a TCP connection. |
| persistent | boolean | false | Whether to use a persistent connection. |
使用例子 | Demo
use OneCk\Client;
use OneCk\Types;
//default
//$ck = new Client('tcp://127.0.0.1:9000');
$t1 = microtime(true);
$ck = new Client('tcp://192.168.31.216:9091', 'default', '123456', 'test1');
$data['server info'] = $ck->getServerInfo();
$data['drop table'] = $ck->query('DROP TABLE IF EXISTS t6');
$table = [
'CREATE TABLE t6 (',
'`id` UInt32,',
'`f1` Int32,',
'`f2` Nullable(Int32),',
'`f3` UInt8,',
'`f4` Nullable(UInt8),',
'`f5` UInt16,',
'`f6` UInt64,',
'`f7` Int64,',
'`f8` Float32,',
'`f9` Float64,',
'`f10` Nullable(Float64),',
'`f11` Decimal32(3),',
'`f12` Decimal64(5),',
'`f13` Decimal128(7),',
'`f14` Nullable(Decimal128(7)),',
'`f15` String,',
'`f16` Nullable(String),',
'`f17` FixedString(32),',
'`f18` UUID,',
'`f19` Date,',
'`f20` Nullable(Date),',
'`f21` Datetime,',
'`f22` Datetime64(3),',
'`f23` IPv4,',
'`f24` Nullable(IPv4),',
'`f25` IPv6,',
'`f26` LowCardinality(String),',
'`f27` Array(Int32),',
'`f28` Array(Array(Array(Nullable(Date)))),',
'`f29` Array(Array(Array(Array(Array(Nullable(Datetime))))))',
') ENGINE = MergeTree() ORDER BY id SETTINGS index_granularity = 8192'
];
$data['create table'] = $ck->query(implode("\n", $table));
$data['insert data'] = $ck->insert('t6', [
[
'id' => 1,
'f1' => -3,
'f2' => null,
'f3' => 127,
'f4' => null,
'f5' => 3322,
'f6' => 1844674407370955161,
'f7' => 9223372036854775807,
'f8' => -2132121.5,
'f9' => 6546546544665.66658,
'f10' => null,
'f11' => 552.339,
'f12' => 3658.6954,
'f13' => '170141183460469231168730371588.4105721',
'f14' => null,
'f15' => 'emoji😀😁😂😃😄',
'f16' => null,
'f17' => md5('a'),
'f18' => '016e64be-605f-4108-8a67-495d74d7ef3c',
'f19' => '2020-09-05',
'f20' => null,
'f21' => '2020-09-05 14:25:12',
'f22' => '2020-09-05 14:25:12.258',
'f23' => '192.168.1.1',
'f24' => null,
'f25' => 'CDCD:910A:2222:5498:8475:1111:3900:2020',
'f26' => 'eee',
'f27' => [0, -2, 3, 4, 5, 6, 7, 8, 64],
'f28' => [[['2020-01-05', null, '2020-01-06']], [['2020-01-07'], ['2020-01-08']], [['2020-01-09']]],
'f29' => [[[[["2020-01-05 05:05:05", null, "2020-01-06 15:16:17"]], [["2020-01-07 18:19:20"], ["2020-01-08 21:22:23"]], [["2020-01-09 00:00:00"]]], [[["2020-01-10 01:00:00", null]]]], [[[["2020-01-11 00:00:01", null, "2020-01-12 11:01:58"]], [["2020-01-13 21:22:01"]]]]]
],
[
'id' => 2,
'f1' => 3,
'f2' => 3,
'f3' => 3,
'f4' => 3,
'f5' => 3,
'f6' => 3,
'f7' => 3,
'f8' => 3,
'f9' => 3,
'f10' => 3,
'f11' => -552.339,
'f12' => -3658.6954,
'f13' => '-170141183460469231168730371588.4105721',
'f14' => 3,
'f15' => str_repeat(md5('aa'), '6'),
'f16' => '',
'f17' => md5('55'),
'f18' => md5('55'),
'f19' => '2020-09-06',
'f20' => '2020-09-06',
'f21' => '2020-09-06 14:25:12',
'f22' => '2020-09-06 14:25:12.258',
'f23' => '251.222.221.231',
'f24' => '192.168.1.2',
'f25' => '1030::C9B4:FF12:48AA:1A2B',
'f26' => 'eee22',
'f27' => [1, 2, 3, 4],
'f28' => [[['2020-01-05', '2020-01-06']], [['2020-01-07', null], ['2020-01-08']], [['2020-01-09']]],
'f29' => [[[[[null]]]]]
],
[
'id' => 3,
'f1' => -1,
'f2' => 3,
'f3' => 3,
'f4' => 3,
'f5' => 3,
'f6' => 3,
'f7' => 3,
'f8' => 3,
'f9' => 3,
'f10' => 3,
'f11' => 3,
'f12' => 3,
'f13' => 3,
'f14' => 3,
'f15' => 'aaa',
'f16' => 'aaa',
'f17' => md5('a'),
'f18' => '3026ee79-ac2a-46d2-882d-959a55d71025',
'f19' => '2020-09-07',
'f20' => '2020-09-07',
'f21' => '2020-09-07 14:25:12',
'f22' => '2020-09-07 14:25:12.258',
'f23' => '192.168.1.1',
'f24' => null,
'f25' => '2001:DB8:2de::e13',
'f26' => 'eee22',
'f27' => [12344],
'f28' => [[['2020-01-05', '2020-01-06'], [null]], [['2020-01-07'], ['2020-01-08']], [['2020-01-09']]],
'f29' => [[[[['2018-01-25 11:25:14']]]]]
]
]);
//$data['struct'] = $ck->query('desc t6');
$data['select t6'] = $ck->query('select * from t6');
$data['select t6 int64'] = $ck->query("select id,f6 from t6 where f6=1844674407370955161");
$data['select t6 Decimal32'] = $ck->query("select id,f11 from t6 where f11='552.339'");
$data['select t6 Decimal64'] = $ck->query("select id,f12 from t6 where f12='-3658.69540'");
$data['select t6 Decimal128'] = $ck->query("select id,f13 from t6 where f13='170141183460469231168730371588.4105721'");
$data['select t6 uuid'] = $ck->query("select id,f18 from t6 where f18='3026ee79-ac2a-46d2-882d-959a55d71025'");
$data['select t6 date'] = $ck->query("select id,f19 from t6 where f19='2020-09-05'");
$data['select t6 datetime'] = $ck->query("select id,f21 from t6 where f21='2020-09-07 20:25:12'");
$data['select t6 datetime64'] = $ck->query("select id,f22 from t6 where f22='2020-09-06 20:25:12.258'");
$data['select t6 ip'] = $ck->query("select id,f23,f25 from t6 where f23=" . Types::encodeIpv4('192.168.1.1'));
$data['select t6 ip64'] = $ck->query("select id,f23,f25 from t6 where f25='" . Types::encodeIpv6('1030::c9b4:ff12:48aa:1a2b') . "'");
$data['nothing'] = $ck->query('select array()');
// flow of write
$data['drop table'] = $ck->query('DROP TABLE IF EXISTS t7');
$table = [
'CREATE TABLE t7 (',
'`id` UInt32,',
'`f2` Nullable(Int32),',
'`f5` UInt16,',
'`f15` String',
') ENGINE = MergeTree() ORDER BY id SETTINGS index_granularity = 8192'
];
$data['create table'] = $ck->query(implode("\n", $table));
$ck->writeStart('t7',['id','f2','f5','f15']);
for ($i = 0; $i < 100; $i++) {
$da = [];
for ($j = 0; $j < 1000; $j++) {
$da[] = [
'id' => mt_rand(1,1000000),
'f2' => mt_rand(-1000000,1000000),
'f5' => mt_rand(1,10000),
'f15' => md5(mt_rand(1,10000))
];
}
$ck->writeBlock($da);
}
$ck->writeEnd();
$data['write 10w rows time'] = microtime(true) - $t1;
echo json_encode($data);
//Close connection
unset($ck);