From 491752c4dd750185e48ada1e6a939ec4ff80e2cf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AB=98=E9=93=81?= Date: Sat, 12 Mar 2016 14:43:29 +0800 Subject: [PATCH] add sql testcases --- .../mysql/ast/expr/MySqlMatchAgainstExpr.java | 7 +- .../mysql/visitor/MySqlOutputVisitor.java | 6 +- .../sql/visitor/SQLASTOutputVisitor.java | 25 ++++--- ...ullTextSearchesWithQueryExpansionTest.java | 36 +++++----- .../bvt/sql/mysql/MySqlCreateTableTest56.java | 20 ++++-- .../bvt/sql/mysql/MySqlCreateTableTest58.java | 69 +++++++++++++++---- .../bvt/sql/mysql/MySqlCreateTableTest60.java | 20 ++++-- .../bvt/sql/mysql/MySqlCreateTableTest61.java | 23 +++++-- .../bvt/sql/mysql/MySqlCreateTableTest62.java | 17 +++-- .../bvt/sql/mysql/MySqlCreateTableTest63.java | 23 +++++-- .../bvt/sql/mysql/MySqlCreateTableTest64.java | 20 ++++-- .../bvt/sql/mysql/MySqlCreateTableTest65.java | 20 ++++-- .../bvt/sql/mysql/MySqlCreateTableTest66.java | 38 ++++++---- .../bvt/sql/mysql/MySqlCreateTableTest67.java | 38 ++++++---- .../bvt/sql/mysql/MySqlCreateTableTest68.java | 48 +++++++++---- .../OceanbaseAlterTableAddPartitionTest.java | 16 +++-- .../OceanbaseAlterTableAddPartitionTest2.java | 17 +++-- ...eanbaseAlterTableAnalyzePartitionTest.java | 18 +++-- ...anbaseAlterTableAnalyzePartitionTest2.java | 17 +++-- ...anbaseAlterTableAnalyzePartitionTest3.java | 66 ++++++++++++++++++ ...OceanbaseAlterTableCheckPartitionTest.java | 17 +++-- ...ceanbaseAlterTableCheckPartitionTest2.java | 18 +++-- ...anbaseAlterTableCoalescePartitionTest.java | 17 +++-- ...eanbaseAlterTableDiscardPartitionTest.java | 17 +++-- ...anbaseAlterTableDiscardPartitionTest2.java | 17 +++-- ...ceanbaseAlterTableImportPartitionTest.java | 17 +++-- ...eanbaseAlterTableImportPartitionTest2.java | 17 +++-- ...anbaseAlterTableOptimizePartitionTest.java | 17 +++-- ...nbaseAlterTableOptimizePartitionTest2.java | 17 +++-- ...baseAlterTableReOrganizePartitionTest.java | 18 +++-- ...aseAlterTableReOrganizePartitionTest2.java | 17 +++-- ...eanbaseAlterTableRebuildPartitionTest.java | 17 +++-- ...anbaseAlterTableRebuildPartitionTest2.java | 19 +++-- ...nbaseAlterTableRemovePartitioningTest.java | 17 +++-- ...ceanbaseAlterTableRepairPartitionTest.java | 17 +++-- ...eanbaseAlterTableRepairPartitionTest2.java | 17 +++-- ...anbaseAlterTableTruncatePartitionTest.java | 17 +++-- ...nbaseAlterTableTruncatePartitionTest2.java | 17 +++-- ...baseAlterTableUpgradePartitioningTest.java | 17 +++-- ...anbaseCreateTableTest_partitionByHash.java | 28 +++++--- ...nbaseCreateTableTest_partitionByHash2.java | 41 +++++++---- ...eanbaseCreateTableTest_partitionByKey.java | 26 ++++--- ...eanbaseCreateTableTest_rangePartition.java | 59 +++++++++++----- ...anbaseCreateTableTest_rangePartition2.java | 59 +++++++++++----- ...anbaseCreateTableTest_rangePartition3.java | 56 ++++++++++----- ...anbaseCreateTableTest_rangePartition4.java | 59 +++++++++++----- ...anbaseCreateTableTest_rangePartition5.java | 38 ++++++---- ...OceanbaseCreateTableTest_subPartition.java | 44 ++++++++---- .../oceanbase/OceanbaseHintTest_Index.java | 17 +++-- 49 files changed, 920 insertions(+), 378 deletions(-) create mode 100644 src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest3.java diff --git a/src/main/java/com/alibaba/druid/sql/dialect/mysql/ast/expr/MySqlMatchAgainstExpr.java b/src/main/java/com/alibaba/druid/sql/dialect/mysql/ast/expr/MySqlMatchAgainstExpr.java index dfc0d3ed1b..3a45c71782 100644 --- a/src/main/java/com/alibaba/druid/sql/dialect/mysql/ast/expr/MySqlMatchAgainstExpr.java +++ b/src/main/java/com/alibaba/druid/sql/dialect/mysql/ast/expr/MySqlMatchAgainstExpr.java @@ -56,11 +56,13 @@ public class MySqlMatchAgainstExpr extends SQLExprImpl implements MySqlExpr { } public static enum SearchModifier { - IN_BOOLEAN_MODE("IN BOOLEAN MODE"), IN_NATURAL_LANGUAGE_MODE("IN NATURAL LANGUAGE MODE"), + IN_BOOLEAN_MODE("IN BOOLEAN MODE"), // + IN_NATURAL_LANGUAGE_MODE("IN NATURAL LANGUAGE MODE"), // IN_NATURAL_LANGUAGE_MODE_WITH_QUERY_EXPANSION("IN NATURAL LANGUAGE MODE WITH QUERY EXPANSION"), - WITH_QUERY_EXPANSION("WITH QUERY EXPANSION"), ; + WITH_QUERY_EXPANSION("WITH QUERY EXPANSION"); public final String name; + public final String name_lcase; SearchModifier(){ this(null); @@ -68,6 +70,7 @@ public class MySqlMatchAgainstExpr extends SQLExprImpl implements MySqlExpr { SearchModifier(String name){ this.name = name; + this.name_lcase = name.toLowerCase(); } } diff --git a/src/main/java/com/alibaba/druid/sql/dialect/mysql/visitor/MySqlOutputVisitor.java b/src/main/java/com/alibaba/druid/sql/dialect/mysql/visitor/MySqlOutputVisitor.java index 645a100b4b..31e8d0be7e 100644 --- a/src/main/java/com/alibaba/druid/sql/dialect/mysql/visitor/MySqlOutputVisitor.java +++ b/src/main/java/com/alibaba/druid/sql/dialect/mysql/visitor/MySqlOutputVisitor.java @@ -500,7 +500,7 @@ public class MySqlOutputVisitor extends SQLASTOutputVisitor implements MySqlASTV String key = option.getKey(); print(' '); - print0(key); + print0(ucase ? key : key.toLowerCase()); if ("TABLESPACE".equals(key)) { print(' '); @@ -812,7 +812,7 @@ public class MySqlOutputVisitor extends SQLASTOutputVisitor implements MySqlASTV x.getAgainst().accept(this); if (x.getSearchModifier() != null) { print(' '); - print0(x.getSearchModifier().name); + print0(ucase ? x.getSearchModifier().name : x.getSearchModifier().name_lcase); } print(')'); @@ -2999,7 +2999,7 @@ public class MySqlOutputVisitor extends SQLASTOutputVisitor implements MySqlASTV x.getExpr().accept(this); if (x.getType() != null) { print(' '); - print0(x.getType().name()); + print0(ucase ? x.getType().name : x.getType().name_lcase); } return false; diff --git a/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java b/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java index 44a1d561e7..02de4511a1 100644 --- a/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java +++ b/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java @@ -2989,56 +2989,65 @@ public class SQLASTOutputVisitor extends SQLASTVisitorAdapter implements Printab @Override public boolean visit(SQLAlterTableTruncatePartition x) { print0(ucase ? "TRUNCATE PARTITION " : "truncate partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } @Override public boolean visit(SQLAlterTableDiscardPartition x) { print0(ucase ? "DISCARD PARTITION " : "discard partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } @Override public boolean visit(SQLAlterTableImportPartition x) { print0(ucase ? "IMPORT PARTITION " : "import partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } @Override public boolean visit(SQLAlterTableAnalyzePartition x) { print0(ucase ? "ANALYZE PARTITION " : "analyze partition "); - printlnAndAccept(x.getPartitions(), ","); + + printPartitions(x.getPartitions()); return false; } + protected void printPartitions(List partitions) { + if (partitions.size() == 1 && "ALL".equalsIgnoreCase(partitions.get(0).getSimpleName())) { + print0(ucase ? "ALL" : "all"); + } else { + printAndAccept(partitions, ", "); + } + } + @Override public boolean visit(SQLAlterTableCheckPartition x) { print0(ucase ? "CHECK PARTITION " : "check partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } @Override public boolean visit(SQLAlterTableOptimizePartition x) { print0(ucase ? "OPTIMIZE PARTITION " : "optimize partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } @Override public boolean visit(SQLAlterTableRebuildPartition x) { print0(ucase ? "REBUILD PARTITION " : "rebuild partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } @Override public boolean visit(SQLAlterTableRepairPartition x) { print0(ucase ? "REPAIR PARTITION " : "repair partition "); - printlnAndAccept(x.getPartitions(), ","); + printPartitions(x.getPartitions()); return false; } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/FullTextSearchesWithQueryExpansionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/FullTextSearchesWithQueryExpansionTest.java index 4556d86e18..71c14a9c25 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/FullTextSearchesWithQueryExpansionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/FullTextSearchesWithQueryExpansionTest.java @@ -18,13 +18,14 @@ package com.alibaba.druid.bvt.sql.mysql; import java.util.List; import org.junit.Assert; -import junit.framework.TestCase; +import com.alibaba.druid.sql.SQLUtils; import com.alibaba.druid.sql.ast.SQLStatement; import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser; -import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlOutputVisitor; import com.alibaba.druid.sql.parser.SQLStatementParser; +import junit.framework.TestCase; + public class FullTextSearchesWithQueryExpansionTest extends TestCase { public void test_0() throws Exception { @@ -32,21 +33,24 @@ public class FullTextSearchesWithQueryExpansionTest extends TestCase { SQLStatementParser parser = new MySqlStatementParser(sql); List stmtList = parser.parseStatementList(); + SQLStatement stmt = stmtList.get(0); - String text = output(stmtList); - - Assert.assertEquals("SELECT *\nFROM articles\nWHERE MATCH (title, body) AGAINST ('database' IN NATURAL LANGUAGE MODE);", - text); - } - - private String output(List stmtList) { - StringBuilder out = new StringBuilder(); - - for (SQLStatement stmt : stmtList) { - stmt.accept(new MySqlOutputVisitor(out)); - out.append(";"); + { + String text = SQLUtils.toMySqlString(stmt); + + Assert.assertEquals("SELECT *" // + + "\nFROM articles" // + + "\nWHERE MATCH (title, body) AGAINST ('database' IN NATURAL LANGUAGE MODE)", + text); + } + { + String text = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + + Assert.assertEquals("select *" // + + "\nfrom articles" // + + "\nwhere match (title, body) against ('database' in natural language mode)", + text); } - - return out.toString(); } + } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest56.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest56.java index a375798610..873034661f 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest56.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest56.java @@ -44,11 +44,19 @@ public class MySqlCreateTableTest56 extends MysqlTest { Assert.assertEquals(1, visitor.getColumns().size()); Assert.assertEquals(0, visitor.getConditions().size()); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE tableA (" // - + "\n\tdatasn varchar(100) NOT NULL, " // - + "\n\tPRIMARY KEY (datasn)" // - + "\n) ENGINE = MRG_MyISAM CHARSET = utf8 UNION = (tableB, tableC)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE tableA (" // + + "\n\tdatasn varchar(100) NOT NULL, " // + + "\n\tPRIMARY KEY (datasn)" // + + "\n) ENGINE = MRG_MyISAM CHARSET = utf8 UNION = (tableB, tableC)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table tableA (" // + + "\n\tdatasn varchar(100) not null, " // + + "\n\tprimary key (datasn)" // + + "\n) engine = MRG_MyISAM charset = utf8 union = (tableB, tableC)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest58.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest58.java index e88ff2fb0f..6274cfe5f7 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest58.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest58.java @@ -46,18 +46,61 @@ public class MySqlCreateTableTest58 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE `appservice_account` (" + "\n\t`id` integer NOT NULL PRIMARY KEY AUTO_INCREMENT, " - + "\n\t`password` varchar(128) NOT NULL, " + "\n\t`last_login` datetime NOT NULL, " - + "\n\t`username` varchar(40) NOT NULL UNIQUE, " + "\n\t`date_of_birth` date NOT NULL, " - + "\n\t`head` varchar(100) NOT NULL, " + "\n\t`headThumb` varchar(100) NOT NULL, " - + "\n\t`name` varchar(50) NOT NULL, " + "\n\t`gender` integer, " + "\n\t`uploadVideoCount` integer NOT NULL, " - + "\n\t`fansCount` integer NOT NULL, " + "\n\t`balance` numeric(19, 2) NOT NULL, " - + "\n\t`brick` integer NOT NULL, " + "\n\t`reward` integer NOT NULL, " + "\n\t`token` varchar(500) NOT NULL, " - + "\n\t`weiboUserid` varchar(50) NOT NULL, " + "\n\t`weiboAccesstoken` varchar(500) NOT NULL, " - + "\n\t`qqUserid` varchar(50) NOT NULL, " + "\n\t`qqAccesstoken` varchar(500) NOT NULL, " - + "\n\t`wechatUserid` varchar(50) NOT NULL, " + "\n\t`wechatAccesstoken` varchar(500) NOT NULL, " - + "\n\t`is_active` bool NOT NULL, " + "\n\t`is_admin` bool NOT NULL" + "\n)",output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE `appservice_account` (" + // + "\n\t`id` integer NOT NULL PRIMARY KEY AUTO_INCREMENT, " + // + "\n\t`password` varchar(128) NOT NULL, " + // + "\n\t`last_login` datetime NOT NULL, " + // + "\n\t`username` varchar(40) NOT NULL UNIQUE, " + // + "\n\t`date_of_birth` date NOT NULL, " + // + "\n\t`head` varchar(100) NOT NULL, " + // + "\n\t`headThumb` varchar(100) NOT NULL, " + // + "\n\t`name` varchar(50) NOT NULL, " + // + "\n\t`gender` integer, " + // + "\n\t`uploadVideoCount` integer NOT NULL, " + // + "\n\t`fansCount` integer NOT NULL, " + // + "\n\t`balance` numeric(19, 2) NOT NULL, " + // + "\n\t`brick` integer NOT NULL, " + // + "\n\t`reward` integer NOT NULL, " + // + "\n\t`token` varchar(500) NOT NULL, " + // + "\n\t`weiboUserid` varchar(50) NOT NULL, " + // + "\n\t`weiboAccesstoken` varchar(500) NOT NULL, " + // + "\n\t`qqUserid` varchar(50) NOT NULL, " + // + "\n\t`qqAccesstoken` varchar(500) NOT NULL, " + // + "\n\t`wechatUserid` varchar(50) NOT NULL, " + // + "\n\t`wechatAccesstoken` varchar(500) NOT NULL, " + // + "\n\t`is_active` bool NOT NULL, " + // + "\n\t`is_admin` bool NOT NULL" + // + "\n)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table `appservice_account` (" + // + "\n\t`id` integer not null primary key auto_increment, " + // + "\n\t`password` varchar(128) not null, " + // + "\n\t`last_login` datetime not null, " + // + "\n\t`username` varchar(40) not null unique, " + // + "\n\t`date_of_birth` date not null, " + // + "\n\t`head` varchar(100) not null, " + // + "\n\t`headThumb` varchar(100) not null, " + // + "\n\t`name` varchar(50) not null, " + // + "\n\t`gender` integer, " + // + "\n\t`uploadVideoCount` integer not null, " + // + "\n\t`fansCount` integer not null, " + // + "\n\t`balance` numeric(19, 2) not null, " + // + "\n\t`brick` integer not null, " + // + "\n\t`reward` integer not null, " + // + "\n\t`token` varchar(500) not null, " + // + "\n\t`weiboUserid` varchar(50) not null, " + // + "\n\t`weiboAccesstoken` varchar(500) not null, " + // + "\n\t`qqUserid` varchar(50) not null, " + // + "\n\t`qqAccesstoken` varchar(500) not null, " + // + "\n\t`wechatUserid` varchar(50) not null, " + // + "\n\t`wechatAccesstoken` varchar(500) not null, " + // + "\n\t`is_active` bool not null, " + // + "\n\t`is_admin` bool not null" + // + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest60.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest60.java index cb9e57b070..617d7dc559 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest60.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest60.java @@ -36,11 +36,19 @@ public class MySqlCreateTableTest60 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t10 (" - + "\n\tpk int PRIMARY KEY AUTO_INCREMENT, " - + "\n\tf1 varchar(65500) CHARSET latin1 " - + "\n)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t10 (" + + "\n\tpk int PRIMARY KEY AUTO_INCREMENT, " + + "\n\tf1 varchar(65500) CHARSET latin1 " + + "\n)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t10 (" + + "\n\tpk int primary key auto_increment, " + + "\n\tf1 varchar(65500) charset latin1 " + + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest61.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest61.java index 8dbf926bdc..ca0b2e6158 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest61.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest61.java @@ -36,12 +36,21 @@ public class MySqlCreateTableTest61 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t (" - + "\n\tpk int PRIMARY KEY AUTO_INCREMENT, " - + "\n\ta timestamp DEFAULT current_timestamp ON UPDATE current_timestamp, " - + "\n\tb timestamp NULL" - + "\n)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t (" + + "\n\tpk int PRIMARY KEY AUTO_INCREMENT, " + + "\n\ta timestamp DEFAULT current_timestamp ON UPDATE current_timestamp, " + + "\n\tb timestamp NULL" + + "\n)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t (" + + "\n\tpk int primary key auto_increment, " + + "\n\ta timestamp default current_timestamp on update current_timestamp, " + + "\n\tb timestamp null" + + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest62.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest62.java index 640ea600bb..e2df2ddba9 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest62.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest62.java @@ -36,10 +36,17 @@ public class MySqlCreateTableTest62 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE a (" - + "\n\tb varchar(15) CHARACTER SET latin1 NULL" - + "\n)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE a (" + + "\n\tb varchar(15) CHARACTER SET latin1 NULL" + + "\n)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table a (" + + "\n\tb varchar(15) character set latin1 null" + + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest63.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest63.java index 17c8e29ac7..11e0e399b7 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest63.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest63.java @@ -36,12 +36,21 @@ public class MySqlCreateTableTest63 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t (" - + "\n\tpk int PRIMARY KEY AUTO_INCREMENT, " - + "\n\ta TIMESTAMP, " - + "\n\tKEY (a DESC)" - + "\n)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t (" + + "\n\tpk int PRIMARY KEY AUTO_INCREMENT, " + + "\n\ta TIMESTAMP, " + + "\n\tKEY (a DESC)" + + "\n)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t (" + + "\n\tpk int primary key auto_increment, " + + "\n\ta TIMESTAMP, " + + "\n\tkey (a desc)" + + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest64.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest64.java index 35b9cfd61c..4193e2af4f 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest64.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest64.java @@ -36,11 +36,19 @@ public class MySqlCreateTableTest64 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t (" - + "\n\tc char(10), " - + "\n\tUNIQUE a USING hash (c(1))" - + "\n) CHARSET = utf8mb4 ENGINE = heap", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t (" + + "\n\tc char(10), " + + "\n\tUNIQUE a USING hash (c(1))" + + "\n) CHARSET = utf8mb4 ENGINE = heap", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t (" + + "\n\tc char(10), " + + "\n\tunique a using hash (c(1))" + + "\n) charset = utf8mb4 engine = heap", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest65.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest65.java index 275620f3ac..2f33d7d2b2 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest65.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest65.java @@ -36,11 +36,19 @@ public class MySqlCreateTableTest65 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t (" - + "\n\tc char(10), " - + "\n\tUNIQUE a USING btree (c(1))" - + "\n) CHARSET = utf8mb4 ENGINE = heap", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t (" + + "\n\tc char(10), " + + "\n\tUNIQUE a USING btree (c(1))" + + "\n) CHARSET = utf8mb4 ENGINE = heap", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t (" + + "\n\tc char(10), " + + "\n\tunique a using btree (c(1))" + + "\n) charset = utf8mb4 engine = heap", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest66.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest66.java index 8abee5c41f..ccdbb00524 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest66.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest66.java @@ -45,17 +45,31 @@ public class MySqlCreateTableTest66 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE hp_db.g20_relationship_communication_daily (" - + "\n\ta_iden_string varchar, " - + "\n\tb_iden_string varchar, " - + "\n\tcounter bigint, " - + "\n\tdurationtime bigint" - + "\n)" - + "\nPARTITION BY HASH KEY(a_iden_string) PARTITION NUM 100" - + "\nSUBPARTITION BY LIST (bdt bigint)" - + "\nSUBPARTITION OPTIONS (available_Partition_Num = 90)" - + "\nTABLEGROUP g20_test_group", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE hp_db.g20_relationship_communication_daily (" + + "\n\ta_iden_string varchar, " + + "\n\tb_iden_string varchar, " + + "\n\tcounter bigint, " + + "\n\tdurationtime bigint" + + "\n)" + + "\nPARTITION BY HASH KEY(a_iden_string) PARTITION NUM 100" + + "\nSUBPARTITION BY LIST (bdt bigint)" + + "\nSUBPARTITION OPTIONS (available_Partition_Num = 90)" + + "\nTABLEGROUP g20_test_group", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table hp_db.g20_relationship_communication_daily (" + + "\n\ta_iden_string varchar, " + + "\n\tb_iden_string varchar, " + + "\n\tcounter bigint, " + + "\n\tdurationtime bigint" + + "\n)" + + "\npartition by hash key(a_iden_string) partition num 100" + + "\nsubpartition by list (bdt bigint)" + + "\nsubpartition options (available_Partition_Num = 90)" + + "\ntablegroup g20_test_group", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest67.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest67.java index a6943a0bf1..f7f5bc208a 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest67.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest67.java @@ -41,17 +41,31 @@ public class MySqlCreateTableTest67 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t1 (" - + "\n\ta INT NOT NULL, " - + "\n\tPRIMARY KEY (a)" - + "\n) ENGINE = InnoDB TABLESPACE ts1" - + "\nPARTITION BY RANGE (a) PARTITIONS 3" - + "\n(" - + "\n\tPARTITION P1 VALUES LESS THAN (2)," - + "\n\tPARTITION P2 VALUES LESS THAN (4) TABLESPACE ts2," - + "\n\tPARTITION P3 VALUES LESS THAN (6) TABLESPACE ts3" - + "\n)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t1 (" + + "\n\ta INT NOT NULL, " + + "\n\tPRIMARY KEY (a)" + + "\n) ENGINE = InnoDB TABLESPACE ts1" + + "\nPARTITION BY RANGE (a) PARTITIONS 3" + + "\n(" + + "\n\tPARTITION P1 VALUES LESS THAN (2)," + + "\n\tPARTITION P2 VALUES LESS THAN (4) TABLESPACE ts2," + + "\n\tPARTITION P3 VALUES LESS THAN (6) TABLESPACE ts3" + + "\n)", output); + } + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t1 (" + + "\n\ta INT not null, " + + "\n\tprimary key (a)" + + "\n) engine = InnoDB tablespace ts1" + + "\npartition by range (a) partitions 3" + + "\n(" + + "\n\tpartition P1 values less than (2)," + + "\n\tpartition P2 values less than (4) tablespace ts2," + + "\n\tpartition P3 values less than (6) tablespace ts3" + + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest68.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest68.java index ce66d8a50c..20bba0a9f9 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest68.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/MySqlCreateTableTest68.java @@ -47,20 +47,38 @@ public class MySqlCreateTableTest68 extends MysqlTest { MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); stmt.accept(visitor); - String output = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE t1 (" - + "\n\tyear_col INT, " - + "\n\tsome_data INT" - + "\n)" - + "\nPARTITION BY RANGE (year_col)" - + "\n(" - + "\n\tPARTITION p0 VALUES LESS THAN (1991)," - + "\n\tPARTITION p1 VALUES LESS THAN (1995)," - + "\n\tPARTITION p2 VALUES LESS THAN (1999)," - + "\n\tPARTITION p3 VALUES LESS THAN (2002)," - + "\n\tPARTITION p4 VALUES LESS THAN (2006)," - + "\n\tPARTITION p5 VALUES LESS THAN MAXVALUE" - + "\n)", output); - + { + String output = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE t1 (" + + "\n\tyear_col INT, " + + "\n\tsome_data INT" + + "\n)" + + "\nPARTITION BY RANGE (year_col)" + + "\n(" + + "\n\tPARTITION p0 VALUES LESS THAN (1991)," + + "\n\tPARTITION p1 VALUES LESS THAN (1995)," + + "\n\tPARTITION p2 VALUES LESS THAN (1999)," + + "\n\tPARTITION p3 VALUES LESS THAN (2002)," + + "\n\tPARTITION p4 VALUES LESS THAN (2006)," + + "\n\tPARTITION p5 VALUES LESS THAN MAXVALUE" + + "\n)", output); + } + + { + String output = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table t1 (" + + "\n\tyear_col INT, " + + "\n\tsome_data INT" + + "\n)" + + "\npartition by range (year_col)" + + "\n(" + + "\n\tpartition p0 values less than (1991)," + + "\n\tpartition p1 values less than (1995)," + + "\n\tpartition p2 values less than (1999)," + + "\n\tpartition p3 values less than (2002)," + + "\n\tpartition p4 values less than (2006)," + + "\n\tpartition p5 values less than maxvalue" + + "\n)", output); + } } } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest.java index e30cbb8c26..897c87ff75 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest.java @@ -34,10 +34,18 @@ public class OceanbaseAlterTableAddPartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE members" - + "\n\tADD PARTITION (PARTITION p3 VALUES LESS THAN (2000))", - result); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE members" + + "\n\tADD PARTITION (PARTITION p3 VALUES LESS THAN (2000))", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table members" + + "\n\tadd partition (partition p3 values less than (2000))", + result); + } print(stmtList); Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest2.java index a279a29846..8b9fcd1808 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAddPartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableAddPartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE clients" - + "\n\tADD PARTITION PARTITIONS 18", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE clients" + + "\n\tADD PARTITION PARTITIONS 18", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table clients" + + "\n\tadd partition partitions 18", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest.java index c90163fa94..6e92fb6e7c 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest.java @@ -33,12 +33,18 @@ public class OceanbaseAlterTableAnalyzePartitionTest extends MysqlTest { MySqlStatementParser parser = new MySqlStatementParser(sql); List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tANALYZE PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tANALYZE PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tanalyze partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest2.java index cb044449d8..885c8d8c9b 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableAnalyzePartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tANALYZE PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tANALYZE PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tanalyze partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest3.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest3.java new file mode 100644 index 0000000000..c4ef84204f --- /dev/null +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableAnalyzePartitionTest3.java @@ -0,0 +1,66 @@ +/* + * Copyright 1999-2101 Alibaba Group Holding Ltd. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.alibaba.druid.bvt.sql.oceanbase; + +import java.util.List; + +import org.junit.Assert; + +import com.alibaba.druid.sql.MysqlTest; +import com.alibaba.druid.sql.SQLUtils; +import com.alibaba.druid.sql.ast.SQLStatement; +import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser; +import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlSchemaStatVisitor; + +public class OceanbaseAlterTableAnalyzePartitionTest3 extends MysqlTest { + + public void test_0() throws Exception { + String sql = "ALTER TABLE tnrange ANALYZE PARTITION p1, p2;"; // + + MySqlStatementParser parser = new MySqlStatementParser(sql); + List stmtList = parser.parseStatementList(); + SQLStatement stmt = stmtList.get(0); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tANALYZE PARTITION p1, p2", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tanalyze partition p1, p2", + result); + } + + Assert.assertEquals(1, stmtList.size()); + + MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); + stmt.accept(visitor); + + System.out.println("Tables : " + visitor.getTables()); + System.out.println("fields : " + visitor.getColumns()); + System.out.println("coditions : " + visitor.getConditions()); + System.out.println("orderBy : " + visitor.getOrderByColumns()); + + Assert.assertEquals(1, visitor.getTables().size()); + Assert.assertEquals(0, visitor.getColumns().size()); + Assert.assertEquals(0, visitor.getConditions().size()); + + // Assert.assertTrue(visitor.getTables().containsKey(new TableStat.Name("t_basic_store"))); + + } +} diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest.java index cf8f516f95..b50609595c 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableCheckPartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tCHECK PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tCHECK PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tcheck partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest2.java index 5be4b1ad35..e15f4964ce 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCheckPartitionTest2.java @@ -33,12 +33,18 @@ public class OceanbaseAlterTableCheckPartitionTest2 extends MysqlTest { MySqlStatementParser parser = new MySqlStatementParser(sql); List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tCHECK PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tCHECK PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tcheck partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCoalescePartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCoalescePartitionTest.java index 53d7eed68d..84ecfd9ad4 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCoalescePartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableCoalescePartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableCoalescePartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE clients" - + "\n\tCOALESCE PARTITION 6", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE clients" + + "\n\tCOALESCE PARTITION 6", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table clients" + + "\n\tcoalesce partition 6", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest.java index 5487bcdd97..2cb3fab340 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableDiscardPartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tDISCARD PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tDISCARD PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tdiscard partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest2.java index 348f106185..ca03f7b443 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableDiscardPartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableDiscardPartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tDISCARD PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tDISCARD PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tdiscard partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest.java index 7b888619cc..9d0ce52bc3 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableImportPartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tIMPORT PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tIMPORT PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\timport partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest2.java index 72db9853ee..b51ce48346 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableImportPartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableImportPartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tIMPORT PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tIMPORT PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\timport partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest.java index 50c57b2665..1fdc118c95 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableOptimizePartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tOPTIMIZE PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tOPTIMIZE PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\toptimize partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest2.java index 4163836b8f..f3dcaf0bc0 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableOptimizePartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableOptimizePartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tOPTIMIZE PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tOPTIMIZE PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\toptimize partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest.java index e4ebb88260..f7a455a37e 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest.java @@ -34,12 +34,18 @@ public class OceanbaseAlterTableReOrganizePartitionTest extends MysqlTest { MySqlStatementParser parser = new MySqlStatementParser(sql); List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE members" - + "\n\tREORGANIZE p0 INTO (PARTITION s0 VALUES LESS THAN (1960), PARTITION s1 VALUES LESS THAN (1970))", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE members" // + + "\n\tREORGANIZE p0 INTO (PARTITION s0 VALUES LESS THAN (1960), PARTITION s1 VALUES LESS THAN (1970))", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table members" // + + "\n\treorganize p0 into (partition s0 values less than (1960), partition s1 values less than (1970))", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest2.java index 308815d09f..9757fab317 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableReOrganizePartitionTest2.java @@ -38,11 +38,18 @@ public class OceanbaseAlterTableReOrganizePartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE members" - + "\n\tREORGANIZE s0, s1, p1, p2, p3 INTO (PARTITION m0 VALUES LESS THAN (1980), PARTITION m1 VALUES LESS THAN (2000))", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE members" + + "\n\tREORGANIZE s0, s1, p1, p2, p3 INTO (PARTITION m0 VALUES LESS THAN (1980), PARTITION m1 VALUES LESS THAN (2000))", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table members" + + "\n\treorganize s0, s1, p1, p2, p3 into (partition m0 values less than (1980), partition m1 values less than (2000))", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest.java index ec13513ac0..c563ed030e 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableRebuildPartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tREBUILD PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tREBUILD PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\trebuild partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest2.java index 6b83f890e1..f963cd53fa 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRebuildPartitionTest2.java @@ -34,12 +34,19 @@ public class OceanbaseAlterTableRebuildPartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tREBUILD PARTITION ALL", - result); - print(stmtList); - + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tREBUILD PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\trebuild partition all", + result); + } + Assert.assertEquals(1, stmtList.size()); MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRemovePartitioningTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRemovePartitioningTest.java index 6e7a047f2f..4e109393c7 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRemovePartitioningTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRemovePartitioningTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableRemovePartitioningTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tREMOVE PARTITIONING", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tREMOVE PARTITIONING", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tremove partitioning", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest.java index 44f06fd0ab..f1abfe8935 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableRepairPartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tREPAIR PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tREPAIR PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\trepair partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest2.java index 5f54e28c35..ebcc3ef872 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableRepairPartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableRepairPartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tREPAIR PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tREPAIR PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\trepair partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest.java index 3407df2b67..b637cb3c2a 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableTruncatePartitionTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tTRUNCATE PARTITION p1", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tTRUNCATE PARTITION p1", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\ttruncate partition p1", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest2.java index 6613bf2fa6..bd16b713f7 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableTruncatePartitionTest2.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableTruncatePartitionTest2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tTRUNCATE PARTITION ALL", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tTRUNCATE PARTITION ALL", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\ttruncate partition all", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableUpgradePartitioningTest.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableUpgradePartitioningTest.java index 758a4fa2e0..fd5bc51825 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableUpgradePartitioningTest.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseAlterTableUpgradePartitioningTest.java @@ -34,11 +34,18 @@ public class OceanbaseAlterTableUpgradePartitioningTest extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("ALTER TABLE tnrange" - + "\n\tUPGRADE PARTITIONING", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("ALTER TABLE tnrange" + + "\n\tUPGRADE PARTITIONING", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("alter table tnrange" + + "\n\tupgrade partitioning", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash.java index 83f46dcef5..15a28da134 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash.java @@ -34,15 +34,25 @@ public class OceanbaseCreateTableTest_partitionByHash extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE tnhash (" - + "\n\tid INT, " - + "\n\tname VARCHAR(5)" - + "\n)" - + "\nPARTITION BY HASH (id) PARTITIONS 2", - result); - print(stmtList); - + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE tnhash (" + + "\n\tid INT, " + + "\n\tname VARCHAR(5)" + + "\n)" + + "\nPARTITION BY HASH (id) PARTITIONS 2", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table tnhash (" + + "\n\tid INT, " + + "\n\tname VARCHAR(5)" + + "\n)" + + "\npartition by hash (id) partitions 2", + result); + } + Assert.assertEquals(1, stmtList.size()); MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash2.java index 31e289bff6..672238e826 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByHash2.java @@ -41,19 +41,34 @@ public class OceanbaseCreateTableTest_partitionByHash2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE employees (" - + "\n\tid INT NOT NULL, " - + "\n\tfname VARCHAR(30), " - + "\n\tlname VARCHAR(30), " - + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " - + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " - + "\n\tjob_code INT, " - + "\n\tstore_id INT" - + "\n)" - + "\nPARTITION BY HASH (YEAR(hired)) PARTITIONS 4", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE employees (" + + "\n\tid INT NOT NULL, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " + + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " + + "\n\tjob_code INT, " + + "\n\tstore_id INT" + + "\n)" + + "\nPARTITION BY HASH (YEAR(hired)) PARTITIONS 4", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table employees (" + + "\n\tid INT not null, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE not null default '1970-01-01', " + + "\n\tseparated DATE not null default '9999-12-31', " + + "\n\tjob_code INT, " + + "\n\tstore_id INT" + + "\n)" + + "\npartition by hash (YEAR(hired)) partitions 4", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByKey.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByKey.java index 494778e74b..acd49cf65c 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByKey.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_partitionByKey.java @@ -34,14 +34,24 @@ public class OceanbaseCreateTableTest_partitionByKey extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE k2 (" - + "\n\tid int PRIMARY KEY, " - + "\n\tname varchar(20)" - + "\n)" - + "\nPARTITION BY KEY () PARTITIONS 2", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE k2 (" + + "\n\tid int PRIMARY KEY, " + + "\n\tname varchar(20)" + + "\n)" + + "\nPARTITION BY KEY () PARTITIONS 2", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table k2 (" + + "\n\tid int primary key, " + + "\n\tname varchar(20)" + + "\n)" + + "\npartition by key () partitions 2", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition.java index 0ba59ee2de..55b7a869c7 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition.java @@ -43,25 +43,46 @@ public class OceanbaseCreateTableTest_rangePartition extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE employees (" - + "\n\tid INT NOT NULL, " - + "\n\tfname VARCHAR(30), " - + "\n\tlname VARCHAR(30), " - + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " - + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " - + "\n\tjob_code INT NOT NULL, " - + "\n\tstore_id INT NOT NULL" - + "\n)" - + "\nPARTITION BY RANGE (store_id)" - + "\n(" - + "\n\tPARTITION p0 VALUES LESS THAN (6)," - + "\n\tPARTITION p1 VALUES LESS THAN (11)," - + "\n\tPARTITION p2 VALUES LESS THAN (16)," - + "\n\tPARTITION p3 VALUES LESS THAN (21)" - + "\n)", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE employees (" + + "\n\tid INT NOT NULL, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " + + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " + + "\n\tjob_code INT NOT NULL, " + + "\n\tstore_id INT NOT NULL" + + "\n)" + + "\nPARTITION BY RANGE (store_id)" + + "\n(" + + "\n\tPARTITION p0 VALUES LESS THAN (6)," + + "\n\tPARTITION p1 VALUES LESS THAN (11)," + + "\n\tPARTITION p2 VALUES LESS THAN (16)," + + "\n\tPARTITION p3 VALUES LESS THAN (21)" + + "\n)", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table employees (" + + "\n\tid INT not null, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE not null default '1970-01-01', " + + "\n\tseparated DATE not null default '9999-12-31', " + + "\n\tjob_code INT not null, " + + "\n\tstore_id INT not null" + + "\n)" + + "\npartition by range (store_id)" + + "\n(" + + "\n\tpartition p0 values less than (6)," + + "\n\tpartition p1 values less than (11)," + + "\n\tpartition p2 values less than (16)," + + "\n\tpartition p3 values less than (21)" + + "\n)", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition2.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition2.java index fb769ddf00..c792a1e6cf 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition2.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition2.java @@ -46,25 +46,46 @@ public class OceanbaseCreateTableTest_rangePartition2 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE employees (" - + "\n\tid INT NOT NULL, " - + "\n\tfname VARCHAR(30), " - + "\n\tlname VARCHAR(30), " - + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " - + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " - + "\n\tjob_code INT NOT NULL, " - + "\n\tstore_id INT NOT NULL" - + "\n)" - + "\nPARTITION BY RANGE (store_id)" - + "\n(" - + "\n\tPARTITION p0 VALUES LESS THAN (6)," - + "\n\tPARTITION p1 VALUES LESS THAN (11)," - + "\n\tPARTITION p2 VALUES LESS THAN (16)," - + "\n\tPARTITION p3 VALUES LESS THAN MAXVALUE" - + "\n)", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE employees (" + + "\n\tid INT NOT NULL, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " + + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " + + "\n\tjob_code INT NOT NULL, " + + "\n\tstore_id INT NOT NULL" + + "\n)" + + "\nPARTITION BY RANGE (store_id)" + + "\n(" + + "\n\tPARTITION p0 VALUES LESS THAN (6)," + + "\n\tPARTITION p1 VALUES LESS THAN (11)," + + "\n\tPARTITION p2 VALUES LESS THAN (16)," + + "\n\tPARTITION p3 VALUES LESS THAN MAXVALUE" + + "\n)", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table employees (" + + "\n\tid INT not null, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE not null default '1970-01-01', " + + "\n\tseparated DATE not null default '9999-12-31', " + + "\n\tjob_code INT not null, " + + "\n\tstore_id INT not null" + + "\n)" + + "\npartition by range (store_id)" + + "\n(" + + "\n\tpartition p0 values less than (6)," + + "\n\tpartition p1 values less than (11)," + + "\n\tpartition p2 values less than (16)," + + "\n\tpartition p3 values less than maxvalue" + + "\n)", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition3.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition3.java index 22b582e7c0..5b7fc38b40 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition3.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition3.java @@ -45,24 +45,44 @@ public class OceanbaseCreateTableTest_rangePartition3 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE employees (" - + "\n\tid INT NOT NULL, " - + "\n\tfname VARCHAR(30), " - + "\n\tlname VARCHAR(30), " - + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " - + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " - + "\n\tjob_code INT NOT NULL, " - + "\n\tstore_id INT NOT NULL" - + "\n)" - + "\nPARTITION BY RANGE (job_code)" - + "\n(" - + "\n\tPARTITION p0 VALUES LESS THAN (100)," - + "\n\tPARTITION p1 VALUES LESS THAN (1000)," - + "\n\tPARTITION p2 VALUES LESS THAN (10000)" - + "\n)", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE employees (" + + "\n\tid INT NOT NULL, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " + + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " + + "\n\tjob_code INT NOT NULL, " + + "\n\tstore_id INT NOT NULL" + + "\n)" + + "\nPARTITION BY RANGE (job_code)" + + "\n(" + + "\n\tPARTITION p0 VALUES LESS THAN (100)," + + "\n\tPARTITION p1 VALUES LESS THAN (1000)," + + "\n\tPARTITION p2 VALUES LESS THAN (10000)" + + "\n)", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table employees (" + + "\n\tid INT not null, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE not null default '1970-01-01', " + + "\n\tseparated DATE not null default '9999-12-31', " + + "\n\tjob_code INT not null, " + + "\n\tstore_id INT not null" + + "\n)" + + "\npartition by range (job_code)" + + "\n(" + + "\n\tpartition p0 values less than (100)," + + "\n\tpartition p1 values less than (1000)," + + "\n\tpartition p2 values less than (10000)" + + "\n)", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition4.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition4.java index d53ef271ae..122b141c54 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition4.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition4.java @@ -45,25 +45,46 @@ public class OceanbaseCreateTableTest_rangePartition4 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE employees (" - + "\n\tid INT NOT NULL, " - + "\n\tfname VARCHAR(30), " - + "\n\tlname VARCHAR(30), " - + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " - + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " - + "\n\tjob_code INT, " - + "\n\tstore_id INT" - + "\n)" - + "\nPARTITION BY RANGE (YEAR(separated))" - + "\n(" - + "\n\tPARTITION p0 VALUES LESS THAN (1991)," - + "\n\tPARTITION p1 VALUES LESS THAN (1996)," - + "\n\tPARTITION p2 VALUES LESS THAN (2001)," - + "\n\tPARTITION p3 VALUES LESS THAN MAXVALUE" - + "\n)", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE employees (" + + "\n\tid INT NOT NULL, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE NOT NULL DEFAULT '1970-01-01', " + + "\n\tseparated DATE NOT NULL DEFAULT '9999-12-31', " + + "\n\tjob_code INT, " + + "\n\tstore_id INT" + + "\n)" + + "\nPARTITION BY RANGE (YEAR(separated))" + + "\n(" + + "\n\tPARTITION p0 VALUES LESS THAN (1991)," + + "\n\tPARTITION p1 VALUES LESS THAN (1996)," + + "\n\tPARTITION p2 VALUES LESS THAN (2001)," + + "\n\tPARTITION p3 VALUES LESS THAN MAXVALUE" + + "\n)", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table employees (" + + "\n\tid INT not null, " + + "\n\tfname VARCHAR(30), " + + "\n\tlname VARCHAR(30), " + + "\n\thired DATE not null default '1970-01-01', " + + "\n\tseparated DATE not null default '9999-12-31', " + + "\n\tjob_code INT, " + + "\n\tstore_id INT" + + "\n)" + + "\npartition by range (YEAR(separated))" + + "\n(" + + "\n\tpartition p0 values less than (1991)," + + "\n\tpartition p1 values less than (1996)," + + "\n\tpartition p2 values less than (2001)," + + "\n\tpartition p3 values less than maxvalue" + + "\n)", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition5.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition5.java index ddfb4eb0ae..8e16aed63d 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition5.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_rangePartition5.java @@ -38,18 +38,32 @@ public class OceanbaseCreateTableTest_rangePartition5 extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE tnrange (" - + "\n\tid INT, " - + "\n\tname VARCHAR(5)" - + "\n)" - + "\nPARTITION BY RANGE (id)" - + "\n(" - + "\n\tPARTITION p1 VALUES LESS THAN (1)," - + "\n\tPARTITION p2 VALUES LESS THAN MAXVALUE" - + "\n)", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE tnrange (" + + "\n\tid INT, " + + "\n\tname VARCHAR(5)" + + "\n)" + + "\nPARTITION BY RANGE (id)" + + "\n(" + + "\n\tPARTITION p1 VALUES LESS THAN (1)," + + "\n\tPARTITION p2 VALUES LESS THAN MAXVALUE" + + "\n)", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table tnrange (" + + "\n\tid INT, " + + "\n\tname VARCHAR(5)" + + "\n)" + + "\npartition by range (id)" + + "\n(" + + "\n\tpartition p1 values less than (1)," + + "\n\tpartition p2 values less than maxvalue" + + "\n)", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_subPartition.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_subPartition.java index a7500c00da..35dee7475c 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_subPartition.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseCreateTableTest_subPartition.java @@ -40,20 +40,36 @@ public class OceanbaseCreateTableTest_subPartition extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("CREATE TABLE ts (" - + "\n\tid INT, " - + "\n\tpurchased DATE" - + "\n)" - + "\nPARTITION BY RANGE (YEAR(purchased))" - + "\nSUBPARTITION BY HASH (TO_DAYS(purchased)) SUBPARTITIONS 2" - + "\n(" - + "\n\tPARTITION p0 VALUES LESS THAN (1990)," - + "\n\tPARTITION p1 VALUES LESS THAN (2000)," - + "\n\tPARTITION p2 VALUES LESS THAN MAXVALUE" - + "\n)", - result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("CREATE TABLE ts (" + + "\n\tid INT, " + + "\n\tpurchased DATE" + + "\n)" + + "\nPARTITION BY RANGE (YEAR(purchased))" + + "\nSUBPARTITION BY HASH (TO_DAYS(purchased)) SUBPARTITIONS 2" + + "\n(" + + "\n\tPARTITION p0 VALUES LESS THAN (1990)," + + "\n\tPARTITION p1 VALUES LESS THAN (2000)," + + "\n\tPARTITION p2 VALUES LESS THAN MAXVALUE" + + "\n)", + result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("create table ts (" + + "\n\tid INT, " + + "\n\tpurchased DATE" + + "\n)" + + "\npartition by range (YEAR(purchased))" + + "\nsubpartition by hash (TO_DAYS(purchased)) subpartitions 2" + + "\n(" + + "\n\tpartition p0 values less than (1990)," + + "\n\tpartition p1 values less than (2000)," + + "\n\tpartition p2 values less than maxvalue" + + "\n)", + result); + } Assert.assertEquals(1, stmtList.size()); diff --git a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseHintTest_Index.java b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseHintTest_Index.java index 054ff096fd..80e10cdba8 100644 --- a/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseHintTest_Index.java +++ b/src/test/java/com/alibaba/druid/bvt/sql/oceanbase/OceanbaseHintTest_Index.java @@ -34,11 +34,18 @@ public class OceanbaseHintTest_Index extends MysqlTest { List stmtList = parser.parseStatementList(); SQLStatement stmt = stmtList.get(0); - String result = SQLUtils.toMySqlString(stmt); - Assert.assertEquals("SELECT /*+ INDEX(t1 i1) , INDEX(t2 i2)*/ *" - + "\nFROM t1, t2" - + "\nWHERE t1.c1 = t2.c1", result); - print(stmtList); + { + String result = SQLUtils.toMySqlString(stmt); + Assert.assertEquals("SELECT /*+ INDEX(t1 i1) , INDEX(t2 i2)*/ *" + + "\nFROM t1, t2" + + "\nWHERE t1.c1 = t2.c1", result); + } + { + String result = SQLUtils.toMySqlString(stmt, SQLUtils.DEFAULT_LCASE_FORMAT_OPTION); + Assert.assertEquals("select /*+ INDEX(t1 i1) , INDEX(t2 i2)*/ *" + + "\nfrom t1, t2" + + "\nwhere t1.c1 = t2.c1", result); + } Assert.assertEquals(1, stmtList.size());