You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-07-30 19:23:07 +03:00
Moved some MTR cases to a new 1pmonly directory. Also added order by clause to few cases
This commit is contained in:
@ -1,26 +0,0 @@
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcol4652;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcol4652;
|
||||
USE mcol4652;
|
||||
|
||||
create table customer (
|
||||
c_custkey decimal(38),
|
||||
c_name varchar (25),
|
||||
c_address varchar (40),
|
||||
c_nationkey int,
|
||||
c_phone char (15),
|
||||
c_acctbal decimal(12,2),
|
||||
c_mktsegment char (10),
|
||||
c_comment varchar (117)
|
||||
) engine=columnstore;
|
||||
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--disable_warnings
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE customer FIELDS TERMINATED BY '|'
|
||||
--enable_warnings
|
||||
SELECT e.min_value, e.max_value FROM information_schema.columnstore_extents e, information_schema.columnstore_columns c where e.object_id = c.object_id and table_schema = 'mcol4652' and column_name = 'c_custkey';
|
||||
DROP DATABASE mcol4652;
|
@ -1,104 +0,0 @@
|
||||
#
|
||||
# Test based on Jira MCOL-4222
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
-- source include/have_innodb.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcol_4222_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcol_4222_db;
|
||||
USE mcol_4222_db;
|
||||
|
||||
#
|
||||
# Scenario-1: Tables with Default NULL
|
||||
#
|
||||
CREATE TABLE t1_i (
|
||||
`C_` varchar(100) DEFAULT NULL
|
||||
) ENGINE=innodb DEFAULT CHARSET=utf8 ;
|
||||
|
||||
CREATE TABLE t1_cs (
|
||||
`C_` varchar(100) DEFAULT NULL
|
||||
) ENGINE=columnstore DEFAULT CHARSET=utf8 ;
|
||||
|
||||
# Populate tables
|
||||
DELIMITER //;
|
||||
CREATE PROCEDURE generate_data()
|
||||
BEGIN NOT ATOMIC
|
||||
DECLARE i INT DEFAULT 0;
|
||||
TRUNCATE TABLE t1_i;
|
||||
TRUNCATE TABLE t1_cs;
|
||||
START TRANSACTION;
|
||||
WHILE i < 70000 DO
|
||||
INSERT INTO t1_i VALUES (i);
|
||||
SET i = i + 1;
|
||||
END WHILE;
|
||||
COMMIT;
|
||||
END//
|
||||
DELIMITER ;//
|
||||
|
||||
CALL generate_data();
|
||||
INSERT INTO t1_cs SELECT * FROM t1_i;
|
||||
SELECT COUNT(*), SUM(t1_i.C_ IS NULL) FROM t1_i;
|
||||
SELECT COUNT(*), SUM(t1_cs.C_ IS NULL) FROM t1_cs;
|
||||
|
||||
# Copy derived CS table to innodb table
|
||||
CREATE TABLE t2 LIKE t1_i;
|
||||
INSERT INTO t2 SELECT * FROM (SELECT * FROM t1_cs) derived;
|
||||
SELECT COUNT(*), SUM(C_ IS NULL) FROM t2;
|
||||
DROP TABLE t2;
|
||||
|
||||
# Copy derived innodb table to CS table
|
||||
CREATE TABLE t2 LIKE t1_cs;
|
||||
INSERT INTO t2 SELECT * FROM (SELECT * FROM t1_i) derived;
|
||||
SELECT COUNT(*), SUM(C_ IS NULL) FROM t2;
|
||||
DROP TABLE t2;
|
||||
|
||||
# Copy derived CS table to another CS table
|
||||
CREATE TABLE t2 LIKE t1_cs;
|
||||
INSERT INTO t2 SELECT * FROM (SELECT * FROM t1_cs) derived;
|
||||
SELECT COUNT(*), SUM(C_ IS NULL) FROM t2;
|
||||
DROP TABLE t2;
|
||||
|
||||
#
|
||||
# Scenario-2: Tables with NOT NULL constraint and a default value
|
||||
#
|
||||
DROP TABLE IF EXISTS t1_i;
|
||||
DROP TABLE IF EXISTS t1_cs;
|
||||
|
||||
CREATE TABLE t1_i (
|
||||
`C_` varchar(100) NOT NULL DEFAULT 123
|
||||
) ENGINE=innodb DEFAULT CHARSET=utf8 ;
|
||||
|
||||
CREATE TABLE t1_cs (
|
||||
`C_` varchar(100) NOT NULL DEFAULT 123
|
||||
) ENGINE=columnstore DEFAULT CHARSET=utf8 ;
|
||||
|
||||
# Populate tables
|
||||
CALL generate_data();
|
||||
INSERT INTO t1_cs SELECT * FROM t1_i;
|
||||
SELECT COUNT(*), SUM(t1_i.C_ IS NULL) FROM t1_i;
|
||||
SELECT COUNT(*), SUM(t1_cs.C_ IS NULL) FROM t1_cs;
|
||||
|
||||
# Copy derived CS table to innodb table
|
||||
CREATE TABLE t2 LIKE t1_i;
|
||||
INSERT INTO t2 SELECT * FROM (SELECT * FROM t1_cs) derived;
|
||||
SELECT * FROM t2 LIMIT 3;
|
||||
DROP TABLE t2;
|
||||
|
||||
# Copy derived innodb table to CS table
|
||||
CREATE TABLE t2 LIKE t1_cs;
|
||||
INSERT INTO t2 SELECT * FROM (SELECT * FROM t1_i) derived;
|
||||
SELECT * FROM t2 LIMIT 3;
|
||||
DROP TABLE t2;
|
||||
|
||||
# Copy derived CS table to another CS table
|
||||
CREATE TABLE t2 LIKE t1_cs;
|
||||
INSERT INTO t2 SELECT * FROM (SELECT * FROM t1_cs) derived;
|
||||
SELECT * FROM t2 LIMIT 3;
|
||||
DROP TABLE t2;
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcol_4222_db;
|
@ -1,47 +0,0 @@
|
||||
#
|
||||
# Test calshowpartitions() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs201_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs201_db;
|
||||
USE mcs201_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='calshowpartitions'`;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION calshowpartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION calshowpartitions;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs201_db;
|
@ -1,54 +0,0 @@
|
||||
#
|
||||
# Test caldisablepartitions() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs202_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs202_db;
|
||||
USE mcs202_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='calshowpartitions'`;
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION calshowpartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
CREATE FUNCTION caldisablepartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
SELECT caldisablepartitions('t1', '0.0.1, 0.1.1');
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION calshowpartitions;
|
||||
DROP FUNCTION caldisablepartitions;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs202_db;
|
@ -1,56 +0,0 @@
|
||||
#
|
||||
# Test calenablepartitions() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs203_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs203_db;
|
||||
USE mcs203_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='calshowpartitions'`;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION calshowpartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
CREATE FUNCTION caldisablepartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
CREATE FUNCTION calenablepartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
SELECT caldisablepartitions('t1', '0.0.1, 0.1.1');
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
SELECT calenablepartitions('t1', '0.0.1');
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION calshowpartitions;
|
||||
DROP FUNCTION caldisablepartitions;
|
||||
DROP FUNCTION calenablepartitions;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs203_db;
|
@ -1,54 +0,0 @@
|
||||
#
|
||||
# Test caldroppartitions() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs204_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs204_db;
|
||||
USE mcs204_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
INSERT INTO t1 SELECT * FROM t1;
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='calshowpartitions'`;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION calshowpartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
CREATE FUNCTION caldroppartitions RETURNS STRING SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
SELECT caldroppartitions('t1', '0.0.1');
|
||||
SELECT calshowpartitions('t1', 'col1');
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION calshowpartitions;
|
||||
DROP FUNCTION caldroppartitions;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs204_db;
|
@ -1,41 +0,0 @@
|
||||
#
|
||||
# Test idbPartition() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs208_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs208_db;
|
||||
USE mcs208_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='idbpartition'`;
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION idbpartition RETURNS STRING SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT idbPartition(col1) FROM t1 LIMIT 1;
|
||||
SELECT idbPartition(col2) FROM t1 LIMIT 1;
|
||||
SELECT idbPartition(col3) FROM t1 LIMIT 1;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION idbpartition;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs208_db;
|
@ -1,40 +0,0 @@
|
||||
#
|
||||
# Test idbDBRoot() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs209_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs209_db;
|
||||
USE mcs209_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='idbdbroot'`;
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION idbdbroot RETURNS INTEGER SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT idbDBRoot(col1) FROM t1 LIMIT 1;
|
||||
SELECT idbDBRoot(col2) FROM t1 LIMIT 1;
|
||||
SELECT idbDBRoot(col3) FROM t1 LIMIT 1;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION idbdbroot;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs209_db;
|
@ -1,40 +0,0 @@
|
||||
#
|
||||
# Test idbPm() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs210_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs210_db;
|
||||
USE mcs210_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='idbpm'`;
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION idbpm RETURNS INTEGER SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT idbPm(col1) FROM t1 LIMIT 1;
|
||||
SELECT idbPm(col2) FROM t1 LIMIT 1;
|
||||
SELECT idbPm(col3) FROM t1 LIMIT 1;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION idbpm;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs210_db;
|
@ -1,39 +0,0 @@
|
||||
#
|
||||
# Test idbExtentRelativeRid() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs214_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs214_db;
|
||||
USE mcs214_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='idbextentrelativerid'`;
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION idbextentrelativerid RETURNS INTEGER SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT idbExtentRelativeRid(col1) FROM t1 WHERE col1=2 LIMIT 1;
|
||||
SELECT idbExtentRelativeRid(col2) FROM t1 WHERE col1=2 LIMIT 1;
|
||||
SELECT idbExtentRelativeRid(col3) FROM t1 WHERE col1=2 LIMIT 1;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION idbextentrelativerid;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs214_db;
|
@ -1,39 +0,0 @@
|
||||
#
|
||||
# Test idbSegment() function
|
||||
# Author: Bharath, bharath.bokka@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs215_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs215_db;
|
||||
USE mcs215_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$MTR_SUITE_DIR/../std_data/100Krows.dat' INTO TABLE t1 FIELDS TERMINATED BY '|';
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $func_exists=`SELECT COUNT(*) FROM mysql.func WHERE name='idbsegment'`;
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
CREATE FUNCTION idbsegment RETURNS INTEGER SONAME "ha_columnstore.so";
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
SELECT idbSegment(col1) FROM t1 WHERE col1=2 LIMIT 1;
|
||||
SELECT idbSegment(col2) FROM t1 WHERE col1=2 LIMIT 1;
|
||||
SELECT idbSegment(col3) FROM t1 WHERE col1=2 LIMIT 1;
|
||||
|
||||
--disable_query_log
|
||||
if (!$func_exists)
|
||||
{
|
||||
DROP FUNCTION idbsegment;
|
||||
}
|
||||
--enable_query_log
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs215_db;
|
@ -27,7 +27,7 @@ t2_dt DATETIME
|
||||
|
||||
INSERT INTO t1 VALUES(1,1111,11.11,'aaaaa','2020-02-01 17:8:19'),
|
||||
(1,2222,22.22,'bbbb','1234-11-21 9:18:16');
|
||||
SELECT * FROM t1;
|
||||
SELECT * FROM t1 ORDER BY t1_int, t1_decimal, t1_varchar, t1_dt;
|
||||
|
||||
INSERT INTO t2 (t2_int,t2_varchar,t2_dt) SELECT t1_int,t1_varchar,t1_dt FROM t1;
|
||||
INSERT INTO t2 (t2_int,t2_varchar,t2_dt) SELECT t1_int,t1_varchar,t1_dt FROM t1 WHERE t1.t1_int=1111;
|
||||
@ -35,7 +35,7 @@ INSERT INTO t2 SELECT * FROM t2;
|
||||
INSERT INTO t2 (t2_char) SELECT (SELECT SUM(LENGTH(t1_varchar)) FROM t1) FROM t1 LIMIT 1;
|
||||
INSERT INTO t2 (t2_char) SELECT (SELECT MAX(LENGTH(t1_varchar)) AS 'var' FROM t1) FROM t1 LIMIT 1;
|
||||
INSERT INTO t2 SELECT * FROM t2 WHERE t2.t2_char='xyz' LIMIT 1;
|
||||
SELECT * FROM t2;
|
||||
SELECT * FROM t2 ORDER BY t2_int, t2_varchar, t2_dt;
|
||||
|
||||
# Negative scenarios
|
||||
--error ER_WRONG_VALUE_COUNT_ON_ROW
|
||||
|
@ -36,14 +36,14 @@ DROP TABLE t1;
|
||||
CREATE TABLE t1 (a INT, b CHAR(10)) ENGINE=Columnstore;
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$datafile' IGNORE INTO TABLE t1 FIELDS TERMINATED BY '' ENCLOSED BY '' IGNORE 1 LINES;
|
||||
SELECT * FROM t1;
|
||||
SELECT * FROM t1 ORDER BY a, b;
|
||||
TRUNCATE TABLE t1;
|
||||
|
||||
--let $datafile=$MTR_SUITE_DIR/../std_data/loaddata4.dat
|
||||
--replace_result $MTR_SUITE_DIR MTR_SUITE_DIR
|
||||
--eval LOAD DATA LOCAL infile '$datafile' IGNORE INTO TABLE t1 FIELDS TERMINATED BY '' ENCLOSED BY '' LINES TERMINATED BY '' IGNORE 1 LINES;
|
||||
# The empty line last comes from the end line field in the file
|
||||
SELECT * FROM t1;
|
||||
SELECT * FROM t1 ORDER BY a, b;
|
||||
--replace_regex /( COLLATE=latin1_swedish_ci)//
|
||||
SHOW CREATE TABLE t1;
|
||||
|
||||
|
@ -1,34 +0,0 @@
|
||||
#
|
||||
# Bulk Load from a central location with distributed data source files
|
||||
# Author: Susil, susil.behera@mariadb.com
|
||||
#
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs48_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs48_db;
|
||||
USE mcs48_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT, col3 CHAR(8)) ENGINE=Columnstore;
|
||||
|
||||
# Load fragmented data source files distributed across pm nodes, cpimport -m2
|
||||
# This test needs to be extended to cover multi-node setup
|
||||
--exec yes | cp $MTR_SUITE_DIR/../std_data/100Krows.dat /tmp
|
||||
|
||||
--disable_result_log #cpimport logs thread/timestamps
|
||||
--exec $MCS_CPIMPORT -m2 mcs48_db t1 -f '/tmp' -l '100Krows.dat';
|
||||
--enable_result_log
|
||||
|
||||
#Validate data
|
||||
SELECT COUNT(*) FROM t1;
|
||||
|
||||
let $rowcount = query_get_value(SELECT COUNT(*) cnt FROM t1, cnt, 1);
|
||||
|
||||
let $match_counts= SELECT $rowcount = 100001;
|
||||
--eval $match_counts
|
||||
|
||||
# Clean UP
|
||||
--exec rm -f /tmp/100Krows.dat
|
||||
DROP DATABASE mcs48_db;
|
@ -1,56 +0,0 @@
|
||||
#
|
||||
# cpimport negative scenarios
|
||||
# Author: Susil, susil.behera@mariadb.com
|
||||
#
|
||||
|
||||
if (!$MYSQL_TEST_ROOT){
|
||||
skip Should be run by root to execute cpimport;
|
||||
}
|
||||
|
||||
-- source ../include/have_columnstore.inc
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS mcs56_db;
|
||||
--enable_warnings
|
||||
|
||||
CREATE DATABASE mcs56_db;
|
||||
USE mcs56_db;
|
||||
|
||||
CREATE TABLE t1(col1 INT, col2 INT) ENGINE=Columnstore;
|
||||
|
||||
# Negative. Non-existing data file.
|
||||
exec rm -f /tmp/nonexisting.dat;
|
||||
--disable_result_log #cpimport logs thread/timestamps
|
||||
exec $MCS_CPIMPORT mcs56_db t1 /tmp/nonexisting.dat 2>&1 | tee /tmp/mcs56.out;
|
||||
--enable_result_log
|
||||
|
||||
exec echo "";
|
||||
exec echo "Check for the correct error message:";
|
||||
exec grep -q "ERR : input data file /tmp/nonexisting.dat does not exist" /tmp/mcs56.out;
|
||||
|
||||
--disable_warnings
|
||||
DROP DATABASE IF EXISTS nonexist_db;
|
||||
DROP DATABASE IF EXISTS nonexist_tbl;
|
||||
--enable_warnings
|
||||
|
||||
# Negative. Non-existing db.
|
||||
--disable_result_log
|
||||
exec $MCS_CPIMPORT nonexist_db t1 /tmp/nonexisting.dat 2>&1 | tee /tmp/mcs56.out;
|
||||
--enable_result_log
|
||||
|
||||
exec echo "";
|
||||
exec echo "Check for the correct error message:";
|
||||
exec grep -q "MCS-2006: 'nonexist_db.t1' does not exist in Columnstore." /tmp/mcs56.out;
|
||||
|
||||
|
||||
# Negative. Non-existing table.
|
||||
--disable_result_log
|
||||
exec $MCS_CPIMPORT mcs56_db nonexist_tbl /tmp/nonexisting.dat 2>&1 | tee /tmp/mcs56.out;
|
||||
--enable_result_log
|
||||
|
||||
exec echo "";
|
||||
exec echo "Check for the correct error message:";
|
||||
exec grep -q "MCS-2006: 'mcs56_db.nonexist_tbl' does not exist in Columnstore." /tmp/mcs56.out;
|
||||
|
||||
# Clean UP
|
||||
DROP DATABASE mcs56_db;
|
Reference in New Issue
Block a user