···

       
119
       
119
       
 
       
		BatchSize:               1000,

     

       
120
       
120
       
 
       
		Logger:                  p.logger,

     

       
121
       
121
       
 
       
		Conn:                    conn,

     

       
122
       
122
       
-
       
		Query:                   "INSERT INTO records (did, rkey, collection, cid, seq, raw, created_at)",

     

       
122
       
122
       
+
       
		Query:                   "INSERT INTO record (did, rkey, collection, cid, seq, raw, created_at)",

     

       
123
       
123
       
 
       
	})

     

       
124
       
124
       
 
       
	if err != nil {

     

       
125
       
125
       
 
       
		return nil, err

     
···

       
131
       
131
       
 
       
		BatchSize:               100,

     

       
132
       
132
       
 
       
		Logger:                  p.logger,

     

       
133
       
133
       
 
       
		Conn:                    conn,

     

       
134
       
134
       
-
       
		Query:                   "INSERT INTO deletes (did, rkey, created_at)",

     

       
134
       
134
       
+
       
		Query:                   "INSERT INTO delete (did, rkey, created_at)",

     

       
135
       
135
       
 
       
	})

     

       
136
       
136
       
 
       
	if err != nil {

     

       
137
       
137
       
 
       
		return nil, err