diff --git a/internal/subscription/repository/sqlite/sqlite_subscription.go b/internal/subscription/repository/sqlite/sqlite_subscription.go
index 658a3f6..6f94903 100644
--- a/internal/subscription/repository/sqlite/sqlite_subscription.go
+++ b/internal/subscription/repository/sqlite/sqlite_subscription.go
@@ -62,7 +62,7 @@ const (
 		secret TEXT,
 		PRIMARY KEY (topic, callback)
 	)`
-	queryIndex  string = `CREATE INDEX idx_subscription ON ` + table + ` (topic, callback);`
+	queryIndex  string = `CREATE INDEX IF NOT EXISTS idx_subscription ON ` + table + ` (topic, callback);`
 	queryCreate string = `INSERT INTO ` + table + ` (created_at, updated_at, synced_at, delete_at, topic, ` +
 		`callback, secret)
 		VALUES (:created_at, :updated_at, :synced_at, :delete_at, :topic, :callback, :secret);`
diff --git a/internal/topic/repository/sqlite/sqlite_topic.go b/internal/topic/repository/sqlite/sqlite_topic.go
index c9873a4..9c571c3 100644
--- a/internal/topic/repository/sqlite/sqlite_topic.go
+++ b/internal/topic/repository/sqlite/sqlite_topic.go
@@ -52,7 +52,7 @@ const (
 		content_type TEXT,
 		content BLOB
 	)`
-	queryIndex  string = `CREATE INDEX idx_topic ON ` + table + ` (url);`
+	queryIndex  string = `CREATE INDEX IF NOT EXISTS idx_topic ON ` + table + ` (url);`
 	queryCreate string = `INSERT INTO ` + table + ` (created_at, updated_at, url, content_type, content)
 		       		VALUES (:created_at, :updated_at, :url, :content_type, :content);`
 	queryFetch  string = `SELECT * FROM ` + table + `;`