diff --git a/typo/src/scala/typo/internal/sqlfiles/readSqlFileDirectories.scala b/typo/src/scala/typo/internal/sqlfiles/readSqlFileDirectories.scala index bc86fa5a00..cf74c9f333 100644 --- a/typo/src/scala/typo/internal/sqlfiles/readSqlFileDirectories.scala +++ b/typo/src/scala/typo/internal/sqlfiles/readSqlFileDirectories.scala @@ -51,7 +51,7 @@ object readSqlFileDirectories { def queryTypeFor(decomposedSql: DecomposedSql, c: Connection): SqlCommandType = { val pc = c.unwrap(classOf[PgConnection]) val q = pc.createQuery(decomposedSql.sqlWithNulls, true, false) - q.query.getSqlCommand.getType + Option(q.query.getSqlCommand).map(_.getType).getOrElse(SqlCommandType.BLANK) } def findSqlFilesUnder(scriptsPath: Path): List[Path] = {