From 672d11522bd6c8d0cedb4081b5297329fea40bdf Mon Sep 17 00:00:00 2001
From: caoliang-web <71004656+caoliang-web@users.noreply.github.com>
Date: Tue, 10 Jan 2023 17:25:06 +0800
Subject: [PATCH] [regression](flink)add flink doris connector case (#15676)

* add flink doris connector case
---
 .../flink_connector_p0/flink_connector.out    |  9 ++++
 .../suites/flink_connector_p0/ddl/create.sql  | 12 ++++++
 .../flink_connector_p0/flink_connector.groovy | 41 +++++++++++++++++++
 3 files changed, 62 insertions(+)
 create mode 100644 regression-test/data/flink_connector_p0/flink_connector.out
 create mode 100644 regression-test/suites/flink_connector_p0/ddl/create.sql
 create mode 100644 regression-test/suites/flink_connector_p0/flink_connector.groovy

diff --git a/regression-test/data/flink_connector_p0/flink_connector.out b/regression-test/data/flink_connector_p0/flink_connector.out
new file mode 100644
index 0000000000..8925552656
--- /dev/null
+++ b/regression-test/data/flink_connector_p0/flink_connector.out
@@ -0,0 +1,9 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !select --
+1	doris	10
+2	spark	20
+3	flink	18
+4	hadoop	30
+5	es	17
+6	hive	20
+
diff --git a/regression-test/suites/flink_connector_p0/ddl/create.sql b/regression-test/suites/flink_connector_p0/ddl/create.sql
new file mode 100644
index 0000000000..c033494c80
--- /dev/null
+++ b/regression-test/suites/flink_connector_p0/ddl/create.sql
@@ -0,0 +1,12 @@
+CREATE TABLE `flink_connector`
+(
+    `order_id`     int NULL,
+    `order_amount` varchar(50) NULL,
+    `order_status` int NULL
+) ENGINE=OLAP
+DUPLICATE KEY(`order_id`)
+COMMENT 'OLAP'
+DISTRIBUTED BY HASH(`order_id`) BUCKETS 10
+PROPERTIES (
+  "replication_num" = "1"
+);
diff --git a/regression-test/suites/flink_connector_p0/flink_connector.groovy b/regression-test/suites/flink_connector_p0/flink_connector.groovy
new file mode 100644
index 0000000000..e3e85ddff2
--- /dev/null
+++ b/regression-test/suites/flink_connector_p0/flink_connector.groovy
@@ -0,0 +1,41 @@
+// 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.
+
+// The cases is copied from https://github.com/trinodb/trino/tree/master
+// /testing/trino-product-tests/src/main/resources/sql-tests/testcases/tpcds
+// and modified by Doris.
+
+
+
+suite("flink_connector") {
+
+    def tableName = "flink_connector"
+    sql """DROP TABLE IF EXISTS ${tableName}"""
+    sql new File("""${context.file.parent}/ddl/create.sql""").text
+    logger.info("start delete local flink doris demo jar...")
+    def delete_local_spark_jar = "rm -rf flink-doris-demo.jar".execute()
+    logger.info("start download flink doris demo ...")
+    logger.info("getS3Url ==== ${getS3Url()}")
+    def download_spark_jar = "curl ${getS3Url()}/regression/flink-doris-demo.jar --output flink-doris-demo.jar".execute().getText()
+    logger.info("finish download spark doris demo ...")
+    def run_cmd = "java -cp flink-doris-demo.jar com.doris.DorisFlinkDfSinkDemo $context.config.feHttpAddress regression_test_flink_connector_p0.$tableName $context.config.feHttpUser"
+    logger.info("run_cmd : $run_cmd")
+    def run_flink_jar = run_cmd.execute().getText()
+    logger.info("result: $run_flink_jar")
+    qt_select """ select * from $tableName order by order_id"""
+
+}