This is an automated email from the ASF dual-hosted git repository.

morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 6b88df2bdd [enhancement](planner) support case transition of timestamp 
datatype when create table (#17305)
6b88df2bdd is described below

commit 6b88df2bdd7c7fc84cfad372c5c6041000d3ede8
Author: LiBinfeng <[email protected]>
AuthorDate: Tue Mar 7 21:03:25 2023 +0800

    [enhancement](planner) support case transition of timestamp datatype when 
create table (#17305)
---
 .../apache/doris/analysis/MultiPartitionDesc.java  |  2 +-
 .../suites/ddl_p0/test_create_table.groovy         | 54 ++++++++++++++++++++++
 2 files changed, 55 insertions(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java 
b/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
index 803123fcb6..76a47e18c6 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/MultiPartitionDesc.java
@@ -228,7 +228,7 @@ public class MultiPartitionDesc implements AllPartitionDesc 
{
             throw new AnalysisException("Multi partition time interval mush be 
larger than zero.");
         }
         try {
-            this.timeUnitType = 
TimestampArithmeticExpr.TimeUnit.valueOf(timeType);
+            this.timeUnitType = 
TimestampArithmeticExpr.TimeUnit.valueOf(timeType.toUpperCase());
         } catch (Exception e) {
             throw new AnalysisException("Multi build partition got an unknow 
time interval type: "
                     + timeType);
diff --git a/regression-test/suites/ddl_p0/test_create_table.groovy 
b/regression-test/suites/ddl_p0/test_create_table.groovy
new file mode 100644
index 0000000000..dd7340cbbb
--- /dev/null
+++ b/regression-test/suites/ddl_p0/test_create_table.groovy
@@ -0,0 +1,54 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you 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.
+
+// this suite is for creating table with timestamp datatype in defferent 
+// case. For example: 'year' and 'Year' datatype should also be valid in 
definition
+
+suite("sql_create_time_range_table") {
+    def testTable = "test_time_range_table"
+
+    sql "DROP TABLE IF EXISTS ${testTable}"
+
+        // multi-line sql
+    def result1 = sql """
+        create table ${testTable} (
+               `actorid` varchar(128),
+               `gameid` varchar(128),
+               `eventtime` datetimev2(3)
+       )
+       engine=olap
+       duplicate key(actorid, gameid, eventtime)
+       partition by range(eventtime)(
+               from ("2000-01-01") to ("2021-01-01") interval 1 year,
+               from ("2021-01-01") to ("2022-01-01") interval 1 MONth,
+               from ("2022-01-01") to ("2023-01-01") interval 1 WEEK,
+               from ("2023-01-01") TO ("2023-02-01") interval 1 DAY
+       )
+       distributed by hash(actorid) buckets 1
+       properties(
+               "replication_num"="1",
+               "light_schema_change"="true",
+               "compression"="zstd",
+               "enable_unique_key_merge_on_write" = "true"
+       );
+               """
+
+    // DDL/DML return 1 row and 1 column, the only value is update row count
+    assertTrue(result1.size() == 1)
+    assertTrue(result1[0].size() == 1)
+    assertTrue(result1[0][0] == 0, "Create table should update 0 rows")
+}


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to