update

fe/fe-core/src/main/java/org/apache/doris/analysis/ExpressionPartitionDesc.java

@@ -295,14 +295,28 @@ public static Map<String, AddPartitionClause> getAddPartitionClauseFromPartition
             List<TPartitionByRange> partitionValues) throws AnalysisException {
         Map<String, AddPartitionClause> result = Maps.newHashMap();
         for (TPartitionByRange partitionValue : partitionValues) {
+            DateTimeFormatter beginDateTimeFormat;
+            LocalDateTime beginTime;
+            LocalDateTime endTime;
+
+            try {
+                beginDateTimeFormat = ExpressionPartitionDesc.probeFormat(partitionValue.start_key.date_literal.value);
+            } catch (AnalysisException e) {
+                throw new RuntimeException(e);
+            }
+            beginTime = ExpressionPartitionDesc.parseStringWithDefaultHSM(partitionValue.start_key.date_literal.value, beginDateTimeFormat);
+            endTime = ExpressionPartitionDesc.parseStringWithDefaultHSM(partitionValue.end_key.date_literal.value, beginDateTimeFormat);
+            String lowerBound = beginTime.format(ExpressionPartitionDesc.DATEKEY_FORMATTER);
+            String upperBound = endTime.format(ExpressionPartitionDesc.DATEKEY_FORMATTER);
+
             // maybe need check the range in FE also, like getAddPartitionClause.
-            PartitionValue lowerValue = new PartitionValue(partitionValue.start_key.date_literal.value);
-            PartitionValue upperValue = new PartitionValue(partitionValue.end_key.date_literal.value);
+            PartitionValue lowerValue = new PartitionValue(lowerBound);
+            PartitionValue upperValue = new PartitionValue(upperBound);
             PartitionKeyDesc partitionKeyDesc = PartitionKeyDesc.createFixed(
                     Collections.singletonList(lowerValue),
                     Collections.singletonList(upperValue));
 
-            String partitionName = "p" + partitionValue.start_key.date_literal.value;
+            String partitionName = "p" + lowerBound;
             Map<String, String> partitionProperties = Maps.newHashMap();
             // here need check
             Short replicationNum = olapTable.getTableProperty().getReplicaAllocation()

fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java

@@ -2865,7 +2865,7 @@ public TCreatePartitionResult createPartition(TCreatePartitionRequest request) t
             TOlapTablePartition tPartition = new TOlapTablePartition();
             tPartition.setId(partition.getId());
             RangePartitionInfo rangePartitionInfo = (RangePartitionInfo) olapTable.getPartitionInfo();
-            Range<PartitionKey> range = rangePartitionInfo.getRange(partition.getId());
+            Range<PartitionKey> range = partitionInfo.getItem(partition.getId()).getItems();
             int partColNum = rangePartitionInfo.getPartitionColumns().size();
             // set start keys
             if (range.hasLowerBound() && !range.lowerEndpoint().isMinValue()) {

fe/fe-core/src/test/java/org/apache/doris/service/FrontendServiceImplTest.java

@@ -0,0 +1,164 @@
+// 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.
+
+package org.apache.doris.service;
+
+
+import org.apache.doris.analysis.CreateDbStmt;
+import org.apache.doris.analysis.CreateTableStmt;
+import org.apache.doris.analysis.ExpressionPartitionDesc;
+import org.apache.doris.analysis.SelectStmt;
+import org.apache.doris.catalog.Database;
+import org.apache.doris.catalog.Env;
+import org.apache.doris.catalog.OlapTable;
+import org.apache.doris.catalog.Partition;
+import org.apache.doris.common.AnalysisException;
+import org.apache.doris.common.Config;
+import org.apache.doris.common.FeConstants;
+import org.apache.doris.qe.ConnectContext;
+import org.apache.doris.thrift.TCreatePartitionRequest;
+import org.apache.doris.thrift.TCreatePartitionResult;
+import org.apache.doris.thrift.TDateLiteral;
+import org.apache.doris.thrift.TExprNode;
+import org.apache.doris.thrift.TPartitionByRange;
+import org.apache.doris.thrift.TStatusCode;
+import org.apache.doris.utframe.UtFrameUtils;
+
+import com.clearspring.analytics.util.Lists;
+import mockit.Mocked;
+import org.junit.AfterClass;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+import java.util.UUID;
+
+public class FrontendServiceImplTest {
+    private static String runningDir = "fe/mocked/FrontendServiceImplTest/" + UUID.randomUUID().toString() + "/";
+
+    @Mocked
+    ExecuteEnv exeEnv;
+
+    private static ConnectContext connectContext;
+    @Rule
+    public ExpectedException expectedException = ExpectedException.none();
+
+    @BeforeClass
+    public static void beforeClass() throws Exception {
+        FeConstants.runningUnitTest = true;
+        FeConstants.default_scheduler_interval_millisecond = 100;
+        Config.dynamic_partition_enable = true;
+        Config.dynamic_partition_check_interval_seconds = 1;
+        UtFrameUtils.createDorisCluster(runningDir);
+        // create connect context
+        connectContext = UtFrameUtils.createDefaultCtx();
+        // create database
+        String createDbStmtStr = "create database test;";
+        CreateDbStmt createDbStmt = (CreateDbStmt) UtFrameUtils.parseAndAnalyzeStmt(createDbStmtStr, connectContext);
+        Env.getCurrentEnv().createDb(createDbStmt);
+    }
+
+    @AfterClass
+    public static void tearDown() {
+        UtFrameUtils.cleanDorisFeDir(runningDir);
+    }
+
+    private static void createTable(String sql) throws Exception {
+        CreateTableStmt createTableStmt = (CreateTableStmt) UtFrameUtils.parseAndAnalyzeStmt(sql, connectContext);
+        Env.getCurrentEnv().createTable(createTableStmt);
+    }
+
+
+    @Test
+    public void testCreatePartitionApi() throws Exception {
+        String createOlapTblStmt = new String("CREATE TABLE test.partition_by_test_newer(\n"
+                + "    event_day DATETIME,\n"
+                + "    site_id INT DEFAULT '10',\n"
+                + "    city_code VARCHAR(100)\n"
+                + ")\n"
+                + "DUPLICATE KEY(event_day, site_id, city_code)\n"
+                + "PARTITION BY date_trunc( event_day,'day') (\n"
+                + "\n"
+                + ")\n"
+                + "DISTRIBUTED BY HASH(event_day, site_id) BUCKETS 32\n"
+                + "PROPERTIES(\"replication_num\" = \"1\");");
+
+        createTable(createOlapTblStmt);
+        Database db = Env.getCurrentInternalCatalog().getDbOrAnalysisException("default_cluster:test");
+        OlapTable table = (OlapTable) db.getTableOrAnalysisException("partition_by_test_newer");
+
+        List<List<TPartitionByRange>> partitionValues = Lists.newArrayList();
+        List<TPartitionByRange> values = Lists.newArrayList();
+        TPartitionByRange range = new TPartitionByRange();
+
+        TExprNode start = new TExprNode();
+        TDateLiteral dateLiteral = new TDateLiteral("2023-08-07 00:00:00");
+        start.setDateLiteral(dateLiteral);
+        range.setStartKey(start);
+
+        TExprNode end = new TExprNode();
+        TDateLiteral dateLiteral2 = new TDateLiteral("2023-08-08 00:00:00");
+        end.setDateLiteral(dateLiteral2);
+        range.setEndKey(end);
+
+        values.add(range);
+        partitionValues.add(values);
+
+        FrontendServiceImpl impl = new FrontendServiceImpl(exeEnv);
+        TCreatePartitionRequest request = new TCreatePartitionRequest();
+        request.setDbId(db.getId());
+        request.setTableId(table.getId());
+        request.setPartitionValues(partitionValues);
+        TCreatePartitionResult partition = impl.createPartition(request);
+
+        Assert.assertEquals(partition.getStatus().getStatusCode(), TStatusCode.OK);
+        Partition p20230807 = table.getPartition("p20230807");
+        Assert.assertNotNull(p20230807);
+
+        String sql = "SELECT * from test.partition_by_test_newer";
+        SelectStmt stmt = (SelectStmt) UtFrameUtils.parseAndAnalyzeStmt(sql, connectContext);
+
+        String str = new String("asd");
+    }
+
+    @Test
+    public void testFormat() {
+        String value = new String("2022-10-11 12:13:23");
+        DateTimeFormatter beginDateTimeFormat;
+        LocalDateTime beginTime;
+
+        try {
+            beginDateTimeFormat = ExpressionPartitionDesc.probeFormat(value);
+        } catch (AnalysisException e) {
+            throw new RuntimeException(e);
+        }
+        beginTime = ExpressionPartitionDesc.parseStringWithDefaultHSM(value, beginDateTimeFormat);
+        String lowerBound = beginTime.format(ExpressionPartitionDesc.DATEKEY_FORMATTER);
+        String lowerBound2 = beginTime.format(ExpressionPartitionDesc.DATE_FORMATTER);
+        String lowerBound3 = beginTime.format(ExpressionPartitionDesc.DATE_TIME_FORMATTER);
+        System.out.println(lowerBound);
+        System.out.println(lowerBound2);
+        System.out.println(lowerBound3);
+        String partitionName = "p" + lowerBound;
+    }
+
+}