--- a/src/SqlHandler.h	Wed Dec 25 01:26:02 2019 +0100
+++ b/src/SqlHandler.h	Wed Dec 25 01:37:05 2019 +0100
@@ -27,8 +27,6 @@
 #include <cassert>
 #include <sys/stat.h>
 
-#include <sqlite3.h>
-
 #include <relpipe/reader/typedefs.h>
 #include <relpipe/reader/TypeId.h>
 #include <relpipe/reader/handlers/RelationalReaderValueHandler.h>
@@ -67,7 +65,7 @@
 
 		for (wchar_t ch; *input >> ch;) {
 			*sql << ch;
-			if (ch == L';' && sqlite3_complete(convertor.to_bytes(sql->str()).c_str())) return true;
+			if (ch == L';' && PreparedStatement::isComplete(convertor.to_bytes(sql->str()).c_str())) return true;
 		}
 
 		string_t remainingSql = sql->str();