Guard against NPE with broken SQL files

oyvindberg · Sep 1, 2023 · 230f4b9 · 230f4b9
1 parent d45eeeb
commit 230f4b9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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] = {