@@ -7,14 +7,12 @@ import (
77)
88
99type MigrationStats struct {
10- Users int
11- Accounts int
12- Books int
13- Notes int
14- Tokens int
15- Sessions int
16- Notifications int
17- EmailPreferences int
10+ Users int
11+ Accounts int
12+ Books int
13+ Notes int
14+ Tokens int
15+ Sessions int
1816}
1917
2018func migrate (pgDB , sqliteDB * sql.DB ) error {
@@ -65,20 +63,6 @@ func migrate(pgDB, sqliteDB *sql.DB) error {
6563 }
6664 fmt .Printf (" Migrated %d sessions\n " , stats .Sessions )
6765
68- // Migrate notifications
69- fmt .Println ("Migrating notifications..." )
70- if err := migrateNotifications (pgDB , tx , & stats ); err != nil {
71- return fmt .Errorf ("migrating notifications: %w" , err )
72- }
73- fmt .Printf (" Migrated %d notifications\n " , stats .Notifications )
74-
75- // Migrate email preferences
76- fmt .Println ("Migrating email preferences..." )
77- if err := migrateEmailPreferences (pgDB , tx , & stats ); err != nil {
78- return fmt .Errorf ("migrating email preferences: %w" , err )
79- }
80- fmt .Printf (" Migrated %d email preferences\n " , stats .EmailPreferences )
81-
8266 // Migrate notes (last so FTS triggers work)
8367 fmt .Println ("Migrating notes..." )
8468 if err := migrateNotes (pgDB , tx , & stats ); err != nil {
@@ -93,14 +77,12 @@ func migrate(pgDB, sqliteDB *sql.DB) error {
9377
9478 // Print summary
9579 fmt .Println ("\n Migration Summary:" )
96- fmt .Printf (" Users: %d\n " , stats .Users )
97- fmt .Printf (" Accounts: %d\n " , stats .Accounts )
98- fmt .Printf (" Books: %d\n " , stats .Books )
99- fmt .Printf (" Notes: %d\n " , stats .Notes )
100- fmt .Printf (" Tokens: %d\n " , stats .Tokens )
101- fmt .Printf (" Sessions: %d\n " , stats .Sessions )
102- fmt .Printf (" Notifications: %d\n " , stats .Notifications )
103- fmt .Printf (" Email Preferences: %d\n " , stats .EmailPreferences )
80+ fmt .Printf (" Users: %d\n " , stats .Users )
81+ fmt .Printf (" Accounts: %d\n " , stats .Accounts )
82+ fmt .Printf (" Books: %d\n " , stats .Books )
83+ fmt .Printf (" Notes: %d\n " , stats .Notes )
84+ fmt .Printf (" Tokens: %d\n " , stats .Tokens )
85+ fmt .Printf (" Sessions: %d\n " , stats .Sessions )
10486
10587 return nil
10688}
@@ -340,79 +322,3 @@ func migrateSessions(pgDB *sql.DB, tx *sql.Tx, stats *MigrationStats) error {
340322
341323 return rows .Err ()
342324}
343-
344- func migrateNotifications (pgDB * sql.DB , tx * sql.Tx , stats * MigrationStats ) error {
345- rows , err := pgDB .Query (`
346- SELECT id, created_at, updated_at, type, user_id
347- FROM notifications
348- ORDER BY id
349- ` )
350- if err != nil {
351- return err
352- }
353- defer rows .Close ()
354-
355- stmt , err := tx .Prepare (`
356- INSERT INTO notifications (id, created_at, updated_at, type, user_id)
357- VALUES (?, ?, ?, ?, ?)
358- ` )
359- if err != nil {
360- return err
361- }
362- defer stmt .Close ()
363-
364- for rows .Next () {
365- var id , userID int
366- var createdAt , updatedAt time.Time
367- var notifType string
368-
369- if err := rows .Scan (& id , & createdAt , & updatedAt , & notifType , & userID ); err != nil {
370- return err
371- }
372-
373- if _ , err := stmt .Exec (id , createdAt , updatedAt , notifType , userID ); err != nil {
374- return err
375- }
376- stats .Notifications ++
377- }
378-
379- return rows .Err ()
380- }
381-
382- func migrateEmailPreferences (pgDB * sql.DB , tx * sql.Tx , stats * MigrationStats ) error {
383- rows , err := pgDB .Query (`
384- SELECT id, created_at, updated_at, user_id, inactive_reminder, product_update
385- FROM email_preferences
386- ORDER BY id
387- ` )
388- if err != nil {
389- return err
390- }
391- defer rows .Close ()
392-
393- stmt , err := tx .Prepare (`
394- INSERT INTO email_preferences (id, created_at, updated_at, user_id, inactive_reminder, product_update)
395- VALUES (?, ?, ?, ?, ?, ?)
396- ` )
397- if err != nil {
398- return err
399- }
400- defer stmt .Close ()
401-
402- for rows .Next () {
403- var id , userID int
404- var createdAt , updatedAt time.Time
405- var inactiveReminder , productUpdate bool
406-
407- if err := rows .Scan (& id , & createdAt , & updatedAt , & userID , & inactiveReminder , & productUpdate ); err != nil {
408- return err
409- }
410-
411- if _ , err := stmt .Exec (id , createdAt , updatedAt , userID , inactiveReminder , productUpdate ); err != nil {
412- return err
413- }
414- stats .EmailPreferences ++
415- }
416-
417- return rows .Err ()
418- }
0 commit comments