Check integrity of sqlite3 file before decoding or tile-joining

Author: e-n-f

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 1.27.12
+
+* Check integrity of sqlite3 file before decoding or tile-joining
+
 ## 1.27.11
 
 * Always include tile and layer in tippecanoe-decode, fixing corrupt JSON.

decode.cpp

@@ -274,6 +274,12 @@ void decode(char *fname, int z, unsigned x, unsigned y, std::set<std::string> co
 			fprintf(stderr, "%s: %s\n", fname, sqlite3_errmsg(db));
 			exit(EXIT_FAILURE);
 		}
+
+		char *err = NULL;
+		if (sqlite3_exec(db, "PRAGMA integrity_check;", NULL, NULL, &err) != SQLITE_OK) {
+			fprintf(stderr, "%s: integrity_check: %s\n", fname, err);
+			exit(EXIT_FAILURE);
+		}
 	}
 
 	if (z < 0) {

enumerate.cpp

@@ -11,6 +11,12 @@ void enumerate(char *fname) {
 		exit(EXIT_FAILURE);
 	}
 
+	char *err = NULL;
+	if (sqlite3_exec(db, "PRAGMA integrity_check;", NULL, NULL, &err) != SQLITE_OK) {
+		fprintf(stderr, "%s: integrity_check: %s\n", fname, err);
+		exit(EXIT_FAILURE);
+	}
+
 	const char *sql = "SELECT zoom_level, tile_column, tile_row from tiles order by zoom_level, tile_column, tile_row;";
 
 	sqlite3_stmt *stmt;

tile-join.cpp

@@ -413,6 +413,12 @@ struct reader *begin_reading(char *fname) {
 			exit(EXIT_FAILURE);
 		}
 
+		char *err = NULL;
+		if (sqlite3_exec(db, "PRAGMA integrity_check;", NULL, NULL, &err) != SQLITE_OK) {
+			fprintf(stderr, "%s: integrity_check: %s\n", fname, err);
+			exit(EXIT_FAILURE);
+		}
+
 		const char *sql = "SELECT zoom_level, tile_column, tile_row, tile_data from tiles order by zoom_level, tile_column, tile_row;";
 		sqlite3_stmt *stmt;
 

version.hpp

@@ -1,6 +1,6 @@
 #ifndef VERSION_HPP
 #define VERSION_HPP
 
-#define VERSION "tippecanoe v1.27.11\n"
+#define VERSION "tippecanoe v1.27.12\n"
 
 #endif