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

[improve](regression) Support qt_target_sql (#34236) (#34270)

Browse Source
This commit is contained in:
walter
2024-04-29 11:50:35 +08:00
committed by GitHub
parent 5277a55791
commit 222289697d
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
View File

@ -850,8 +850,9 @@ class Suite implements GroovyInterceptable {
tupleResult = JdbcUtils.executeToStringList(context.getHiveRemoteConnection(), (PreparedStatement) arg)
} else if (tag.contains("arrow_flight_sql") || context.useArrowFlightSql()) {
tupleResult = JdbcUtils.executeToStringList(context.getArrowFlightSqlConnection(), (PreparedStatement) arg)
}
else{
} else if (tag.contains("target_sql")) {
tupleResult = JdbcUtils.executeToStringList(context.getTargetConnection(this), (PreparedStatement) arg)
} else {
tupleResult = JdbcUtils.executeToStringList(context.getConnection(), (PreparedStatement) arg)
}
} else {
@ -862,8 +863,9 @@ class Suite implements GroovyInterceptable {
} else if (tag.contains("arrow_flight_sql") || context.useArrowFlightSql()) {
tupleResult = JdbcUtils.executeToStringList(context.getArrowFlightSqlConnection(),
(String) ("USE ${context.dbName};" + (String) arg))
}
else{
} else if (tag.contains("target_sql")) {
tupleResult = JdbcUtils.executeToStringList(context.getTargetConnection(this), (String) arg)
} else {
tupleResult = JdbcUtils.executeToStringList(context.getConnection(), (String) arg)
}
}
@ -893,8 +895,9 @@ class Suite implements GroovyInterceptable {
tupleResult = JdbcUtils.executeToStringList(context.getHiveRemoteConnection(), (PreparedStatement) arg)
} else if (tag.contains("arrow_flight_sql") || context.useArrowFlightSql()) {
tupleResult = JdbcUtils.executeToStringList(context.getArrowFlightSqlConnection(), (PreparedStatement) arg)
}
else{
} else if (tag.contains("target_sql")) {
tupleResult = JdbcUtils.executeToStringList(context.getTargetConnection(this), (PreparedStatement) arg)
} else {
tupleResult = JdbcUtils.executeToStringList(context.getConnection(), (PreparedStatement) arg)
}
} else {
@ -905,8 +908,9 @@ class Suite implements GroovyInterceptable {
} else if (tag.contains("arrow_flight_sql") || context.useArrowFlightSql()) {
tupleResult = JdbcUtils.executeToStringList(context.getArrowFlightSqlConnection(),
(String) ("USE ${context.dbName};" + (String) arg))
}
else{
} else if (tag.contains("target_sql")) {
tupleResult = JdbcUtils.executeToStringList(context.getTargetConnection(this), (String) arg)
} else {
tupleResult = JdbcUtils.executeToStringList(context.getConnection(), (String) arg)
}
}