database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](jdbc) fix create table like table of jdbc error (#15179)

Browse Source 
when create table like table of jdbc, it will get error like
'errCode = 2, detailMessage = Failed to execute CREATE TABLE LIKE baseall_mysql.
Reason: errCode = 2, detailMessage = property table_type must be set'
this pr fix it.
This commit is contained in:
xueweizhang
2022-12-21 08:56:43 +08:00
committed by GitHub
parent 732417258c
commit 8969c19cd4
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
View File

@ -3112,7 +3112,8 @@ public class Env {
addTableComment(jdbcTable, sb);
sb.append("\nPROPERTIES (\n");
sb.append("\"resource\" = \"").append(jdbcTable.getResourceName()).append("\",\n");
sb.append("\"table\" = \"").append(jdbcTable.getJdbcTable()).append("\"");
sb.append("\"table\" = \"").append(jdbcTable.getJdbcTable()).append("\",\n");
sb.append("\"table_type\" = \"").append(jdbcTable.getJdbcTypeName()).append("\"");
sb.append("\n)");
}

9
regression-test/suites/external_table_emr_p2/mysql/test_external_resource_mysql.groovy
View File

@ -26,6 +26,7 @@ suite("test_external_resource_mysql", "p2") {
String mysqlResourceName = "jdbc_resource_mysql_57"
String mysqlDatabaseName01 = "external_mysql_database01"
String mysqlTableName01 = "external_mysql_table01"
String mysqlTableName02 = "external_mysql_table02"
sql """drop resource if exists ${mysqlResourceName};"""
sql """
@ -58,7 +59,14 @@ suite("test_external_resource_mysql", "p2") {
def res = sql """select count(*) from ${mysqlTableName01};"""
logger.info("recoding select: " + res.toString())
sql """
CREATE EXTERNAL TABLE ${mysqlTableName02} LIKE ${mysqlTableName01};
"""
res = sql """select count(*) from ${mysqlTableName02};"""
logger.info("recoding select: " + res.toString())
sql """drop table if exists ${mysqlTableName01}"""
sql """drop table if exists ${mysqlTableName02}"""
sql """drop database if exists ${mysqlDatabaseName01};"""
}
@ -70,3 +78,4 @@ suite("test_external_resource_mysql", "p2") {