diff --git a/pkg/expr/sql/db.go b/pkg/expr/sql/db.go index 1e7aca0c1b6..90e23342c4b 100644 --- a/pkg/expr/sql/db.go +++ b/pkg/expr/sql/db.go @@ -9,10 +9,6 @@ import ( type DB struct { } -func (db *DB) TablesList(rawSQL string) ([]string, error) { - return nil, errors.New("not implemented") -} - func (db *DB) RunCommands(commands []string) (string, error) { return "", errors.New("not implemented") } diff --git a/pkg/expr/sql/parser.go b/pkg/expr/sql/parser.go index a5ca1fb6f5b..b5456b3b6ff 100644 --- a/pkg/expr/sql/parser.go +++ b/pkg/expr/sql/parser.go @@ -20,10 +20,10 @@ var logger = log.New("sql_expr") // TablesList returns a list of tables for the sql statement func TablesList(rawSQL string) ([]string, error) { - duckDB := NewInMemoryDB() + db := NewInMemoryDB() rawSQL = strings.Replace(rawSQL, "'", "''", -1) cmd := fmt.Sprintf("SELECT json_serialize_sql('%s')", rawSQL) - ret, err := duckDB.RunCommands([]string{cmd}) + ret, err := db.RunCommands([]string{cmd}) if err != nil { logger.Error("error serializing sql", "error", err.Error(), "sql", rawSQL, "cmd", cmd) return nil, fmt.Errorf("error serializing sql: %s", err.Error())