added queries

tpch-ssdb_ddl.sql

@@ -0,0 +1,98 @@
+DROP DATABASE IF EXISTS tpch;
+CREATE DATABASE tpch;
+USE tpch;
+
+CREATE TABLE `customer` (
+`c_custkey` int(11) NOT NULL,
+`c_name` varchar(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`c_address` varchar(40) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`c_nationkey` int(11) NOT NULL,
+`c_phone` char(15) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`c_acctbal` decimal(15,2) NOT NULL,
+`c_mktsegment` char(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`c_comment` varchar(117) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`c_custkey`) USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `lineitem` (
+`l_orderkey` bigint(11) NOT NULL,
+`l_partkey` int(11) NOT NULL,
+`l_suppkey` int(11) NOT NULL,
+`l_linenumber` int(11) NOT NULL,
+`l_quantity` decimal(15,2) NOT NULL,
+`l_extendedprice` decimal(15,2) NOT NULL,
+`l_discount` decimal(15,2) NOT NULL,
+`l_tax` decimal(15,2) NOT NULL,
+`l_returnflag` char(1) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`l_linestatus` char(1) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`l_shipdate` date NOT NULL,
+`l_commitdate` date NOT NULL,
+`l_receiptdate` date NOT NULL,
+`l_shipinstruct` char(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`l_shipmode` char(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`l_comment` varchar(44) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`l_orderkey`) USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `nation` (
+`n_nationkey` int(11) NOT NULL,
+`n_name` char(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`n_regionkey` int(11) NOT NULL,
+`n_comment` varchar(152) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`n_nationkey`) USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `orders` (
+`o_orderkey` bigint(11) NOT NULL,
+`o_custkey` int(11) NOT NULL,
+`o_orderstatus` char(1) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`o_totalprice` decimal(15,2) NOT NULL,
+`o_orderdate` date NOT NULL,
+`o_orderpriority` char(15) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`o_clerk` char(15) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`o_shippriority` int(11) NOT NULL,
+`o_comment` varchar(79) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`o_orderkey`) USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `part` (
+`p_partkey` int(11) NOT NULL,
+`p_name` varchar(55) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`p_mfgr` char(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`p_brand` char(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`p_type` varchar(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`p_size` int(11) NOT NULL,
+`p_container` char(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`p_retailprice` decimal(15,2) NOT NULL,
+`p_comment` varchar(23) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`p_partkey`) USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `partsupp` (
+`ps_partkey` int(11) NOT NULL,
+`ps_suppkey` int(11) NOT NULL,
+`ps_availqty` int(11) NOT NULL,
+`ps_supplycost` decimal(15,2) NOT NULL,
+`ps_comment` varchar(199) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY(`ps_partkey`),
+KEY (`ps_partkey`,`ps_suppkey`)  USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `region` (
+`r_regionkey` int(11) NOT NULL,
+`r_name` char(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`r_comment` varchar(152) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`r_regionkey`) USING CLUSTERED COLUMNSTORE
+);
+
+CREATE TABLE `supplier` (
+`s_suppkey` int(11) NOT NULL,
+`s_name` char(25) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`s_address` varchar(40) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`s_nationkey` int(11) NOT NULL,
+`s_phone` char(15) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+`s_acctbal` decimal(15,2) NOT NULL,
+`s_comment` varchar(101) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
+SHARD KEY (`s_suppkey`) USING CLUSTERED COLUMNSTORE
+);
+

tpch_clickhouse_ddl.sql

@@ -0,0 +1,92 @@
+create database tpch;
+USE tpch;
+
+CREATE TABLE `customer` (
+  `c_custkey` UInt32 ,
+  `c_name` String ,
+  `c_address` String  ,
+  `c_nationkey` UInt32 ,
+  `c_phone` String ,
+  `c_acctbal` Float32 ,
+  `c_mktsegment` String ,
+  `c_comment` String)
+  ENGINE = MergeTree ORDER BY c_custkey ;
+
+CREATE TABLE `lineitem` (
+  `l_orderkey` UInt32 ,
+  `l_partkey` UInt32 ,
+  `l_suppkey` UInt32 ,
+  `l_linenumber` UInt32 ,
+  `l_quantity` Float32 ,
+  `l_extendedprice` Float32 ,
+  `l_discount` Float32 ,
+  `l_tax` Float32 ,
+  `l_returnflag` String ,
+  `l_linestatus` String,
+  `l_shipdate` date ,
+  `l_commitdate` date ,
+  `l_receiptdate` date ,
+  `l_shipinstruct` String ,
+  `l_shipmode` String ,
+  `l_comment` String )
+   ENGINE = MergeTree  ORDER BY l_orderkey ;
+;
+CREATE TABLE `nation` (
+  `n_nationkey` UInt32 ,
+  `n_name` String ,
+  `n_regionkey` UInt32 ,
+  `n_comment` String )
+ ENGINE = MergeTree  ORDER BY n_nationkey ;
+;
+CREATE TABLE `orders` (
+  `o_orderkey` UInt32 ,
+  `o_custkey` UInt32 ,
+  `o_orderstatus` String ,
+  `o_totalprice` Float32 ,
+  `o_orderdate` date ,
+  `o_orderpriority` String ,
+  `o_clerk`  String ,
+  `o_shippriority` UInt32 ,
+  `o_comment`  String)
+  ENGINE = MergeTree  ORDER BY o_orderkey ;
+
+CREATE TABLE `part` (
+  `p_partkey` UInt32 ,
+  `p_name`  String ,
+  `p_mfgr` String ,
+  `p_brand` String ,
+  `p_type` String ,
+  `p_size` UInt32 ,
+  `p_container` String ,
+  `p_retailprice` Float32 ,
+  `p_comment` String)
+   ENGINE = MergeTree  ORDER BY p_partkey ;
+
+drop table partsupp;
+CREATE TABLE `partsupp` (
+  `ps_partkey` UInt32 ,
+  `ps_suppkey` UInt32 ,
+  `ps_availqty` UInt32 ,
+  `ps_supplycost` Float32 ,
+  `ps_comment` String)
+     ENGINE MergeTree ORDER BY ps_partkey ;
+
+
+
+
+
+CREATE TABLE `region` (
+  `r_regionkey` UInt32 ,
+  `r_name` String ,
+  `r_comment` String)
+   ENGINE = MergeTree  ORDER BY r_regionkey ;
+
+CREATE TABLE `supplier` (
+  `s_suppkey` UInt32 ,
+  `s_name` String ,
+  `s_address` String ,
+  `s_nationkey` UInt32 ,
+  `s_phone` String ,
+  `s_acctbal` Float32 ,
+  `s_comment` String)
+   ENGINE = MergeTree  ORDER BY s_suppkey ;