feat: deleted time added to the database

internal/database/migrations/mysql/0005_deleted_at.up.sql

@@ -0,0 +1,4 @@
+CREATE TABLE IF NOT EXISTS deleted(
+    id INT(11) NOT NULL,
+    deleted_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

internal/database/migrations/postgres/0002_deleted_at.up.sql

@@ -0,0 +1,4 @@
+CREATE TABLE IF NOT EXISTS deleted(
+    id            INTEGER      NOT NULL,
+	deleted_at    TIMESTAMP(0) NOT NULL DEFAULT CURRENT_TIMESTAMP
+    );

internal/database/migrations/sqlite/0004_deleted_at.up.sql

@@ -0,0 +1,4 @@
+CREATE TABLE IF NOT EXISTS deleted(
+    id INTEGER NOT NULL,
+    deleted_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP
+    );

internal/database/mysql.go

@@ -61,6 +61,7 @@
 
 		return nil
 	}),
+	newFileMigration("0.7.0", "0.8.0", "mysql/0005_deleted_at"),
 }
 
 // MySQLDatabase is implementation of Database interface
@@ -518,6 +519,7 @@
 		// Prepare queries
 		delBookmark := `DELETE FROM bookmark`
 		delBookmarkTag := `DELETE FROM bookmark_tag`
+		delBookmarkTime := `INSERT INTO deleted (id, deleted_at) VALUES(?,?)`
 
 		// Delete bookmark(s)
 		if len(ids) == 0 {
@@ -530,9 +532,15 @@
 			if err != nil {
 				return errors.WithStack(err)
 			}
+			deletedTime := time.Now().UTC().Format(model.DatabaseDateFormat)
+			_, err = tx.ExecContext(ctx, delBookmarkTime, ids, deletedTime)
+			if err != nil {
+				return errors.WithStack(err)
+			}
 		} else {
 			delBookmark += ` WHERE id = ?`
 			delBookmarkTag += ` WHERE bookmark_id = ?`
+			delBookmarkTime := `INSERT INTO deleted (id, deleted_at) VALUES(?,?)`
 
 			stmtDelBookmark, _ := tx.Preparex(delBookmark)
 			stmtDelBookmarkTag, _ := tx.Preparex(delBookmarkTag)
@@ -547,6 +555,11 @@
 				if err != nil {
 					return errors.WithStack(err)
 				}
+				deletedTime := time.Now().UTC().Format(model.DatabaseDateFormat)
+				_, err = tx.ExecContext(ctx, delBookmarkTime, id, deletedTime)
+				if err != nil {
+					return errors.WithStack(err)
+				}
 			}
 		}
 

internal/database/pg.go

@@ -57,6 +57,7 @@
 
 		return nil
 	}),
+	newFileMigration("0.3.0", "0.4.0", "postgres/0002_deleted_at"),
 }
 
 // PGDatabase is implementation of Database interface
@@ -518,6 +519,7 @@
 		// Prepare queries
 		delBookmark := `DELETE FROM bookmark`
 		delBookmarkTag := `DELETE FROM bookmark_tag`
+		delBookmarktime := `INSERT INTO deleted (id, deleted_at) VALUES ($1, $2) `
 
 		// Delete bookmark(s)
 		if len(ids) == 0 {
@@ -530,9 +532,15 @@
 			if err != nil {
 				return errors.WithStack(err)
 			}
+			deletedTime := time.Now().UTC().Format(model.DatabaseDateFormat)
+			_, err = tx.ExecContext(ctx, delBookmarktime, ids, deletedTime)
+			if err != nil {
+				return errors.WithStack(err)
+			}
 		} else {
 			delBookmark += ` WHERE id = $1`
 			delBookmarkTag += ` WHERE bookmark_id = $1`
+			delBookmarktime := `INSERT INTO deleted (id, deleted_at) VALUES ($1, $2) `
 
 			stmtDelBookmark, err := tx.Preparex(delBookmark)
 			if err != nil {
@@ -553,6 +561,11 @@
 				if err != nil {
 					return errors.WithStack(err)
 				}
+				deletedTime := time.Now().UTC().Format(model.DatabaseDateFormat)
+				_, err = tx.ExecContext(ctx, delBookmarktime, id, deletedTime)
+				if err != nil {
+					return errors.WithStack(err)
+				}
 			}
 		}
 

internal/database/sqlite.go

@@ -60,6 +60,7 @@
 	}),
 	newFileMigration("0.3.0", "0.4.0", "sqlite/0002_denormalize_content"),
 	newFileMigration("0.4.0", "0.5.0", "sqlite/0003_uniq_id"),
+	newFileMigration("0.5.0", "0.6.0", "sqlite/0004_deleted_at"),
 }
 
 // SQLiteDatabase is implementation of Database interface
@@ -601,6 +602,7 @@
 		delBookmark := `DELETE FROM bookmark`
 		delBookmarkTag := `DELETE FROM bookmark_tag`
 		delBookmarkContent := `DELETE FROM bookmark_content`
+		delBookmarktime := `INSERT INTO deleted (id, deleted_at) VALUES(?,?)`
 
 		// Delete bookmark(s)
 		if len(ids) == 0 {
@@ -618,10 +620,16 @@
 			if err != nil {
 				return errors.WithStack(err)
 			}
+			deletedTime := time.Now().UTC().Format(model.DatabaseDateFormat)
+			_, err = tx.ExecContext(ctx, delBookmarktime, ids, deletedTime)
+			if err != nil {
+				return errors.WithStack(err)
+			}
 		} else {
 			delBookmark += ` WHERE id = ?`
 			delBookmarkTag += ` WHERE bookmark_id = ?`
 			delBookmarkContent += ` WHERE docid = ?`
+			delBookmarktime := `INSERT INTO deleted (id, deleted_at) VALUES(?,?)`
 
 			stmtDelBookmark, err := tx.Preparex(delBookmark)
 			if err != nil {
@@ -653,6 +661,11 @@
 				if err != nil {
 					return errors.WithStack(err)
 				}
+				deletedTime := time.Now().UTC().Format(model.DatabaseDateFormat)
+				_, err = tx.ExecContext(ctx, delBookmarktime, id, deletedTime)
+				if err != nil {
+					return errors.WithStack(err)
+				}
 			}
 		}