Skip to content

Commit 88f9b8a

Browse files
authored
Merge pull request byzer-org#1278 from zml1206/master
fix directQuery auth 'select' match
2 parents 9e5bf47 + de8ef00 commit 88f9b8a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

streamingpro-mlsql/src/main/java/streaming/core/datasource/impl/MLSQLDirectJDBC.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ class MLSQLDirectJDBC extends MLSQLDirectSource with MLSQLDirectSink with MLSQLS
153153
val sql = params("directQuery")
154154
val dbType = params.getOrElse("dbType", JdbcConstants.MYSQL)
155155
// first, only select supports
156-
if (!sql.trim.toLowerCase.startsWith("select ")) {
156+
if (!sql.trim.toLowerCase.startsWith("select")) {
157157
throw new MLSQLException("JDBC direct query only support select statement")
158158
}
159159
logInfo("Auth direct query tables.... ")

0 commit comments

Comments
 (0)