]> Untitled Git - lemmy.git/blobdiff - src/code_migrations.rs
Merge remote-tracking branch 'origin/split-db-workspace' into move_views_to_diesel_split
[lemmy.git] / src / code_migrations.rs
index c3026a93b2905fa2dbece9ba359a948efed7cc55..73b030cb22dc2f39e53165b1247b2bb6419acafc 100644 (file)
@@ -46,8 +46,6 @@ fn user_updates_2020_04_02(conn: &PgConnection) -> Result<(), LemmyError> {
     .filter(local.eq(true))
     .load::<User_>(conn)?;
 
-  sql_query("alter table user_ disable trigger refresh_user").execute(conn)?;
-
   for cuser in &incorrect_users {
     let keypair = generate_actor_keypair()?;
 
@@ -81,8 +79,6 @@ fn user_updates_2020_04_02(conn: &PgConnection) -> Result<(), LemmyError> {
     User_::update(&conn, cuser.id, &form)?;
   }
 
-  sql_query("alter table user_ enable trigger refresh_user").execute(conn)?;
-
   info!("{} user rows updated.", incorrect_users.len());
 
   Ok(())
@@ -99,8 +95,6 @@ fn community_updates_2020_04_02(conn: &PgConnection) -> Result<(), LemmyError> {
     .filter(local.eq(true))
     .load::<Community>(conn)?;
 
-  sql_query("alter table community disable trigger refresh_community").execute(conn)?;
-
   for ccommunity in &incorrect_communities {
     let keypair = generate_actor_keypair()?;
 
@@ -127,8 +121,6 @@ fn community_updates_2020_04_02(conn: &PgConnection) -> Result<(), LemmyError> {
     Community::update(&conn, ccommunity.id, &form)?;
   }
 
-  sql_query("alter table community enable trigger refresh_community").execute(conn)?;
-
   info!("{} community rows updated.", incorrect_communities.len());
 
   Ok(())
@@ -145,8 +137,6 @@ fn post_updates_2020_04_03(conn: &PgConnection) -> Result<(), LemmyError> {
     .filter(local.eq(true))
     .load::<Post>(conn)?;
 
-  sql_query("alter table post disable trigger refresh_post").execute(conn)?;
-
   for cpost in &incorrect_posts {
     let apub_id = make_apub_endpoint(EndpointType::Post, &cpost.id.to_string()).to_string();
     Post::update_ap_id(&conn, cpost.id, apub_id)?;
@@ -154,8 +144,6 @@ fn post_updates_2020_04_03(conn: &PgConnection) -> Result<(), LemmyError> {
 
   info!("{} post rows updated.", incorrect_posts.len());
 
-  sql_query("alter table post enable trigger refresh_post").execute(conn)?;
-
   Ok(())
 }
 
@@ -170,15 +158,11 @@ fn comment_updates_2020_04_03(conn: &PgConnection) -> Result<(), LemmyError> {
     .filter(local.eq(true))
     .load::<Comment>(conn)?;
 
-  sql_query("alter table comment disable trigger refresh_comment").execute(conn)?;
-
   for ccomment in &incorrect_comments {
     let apub_id = make_apub_endpoint(EndpointType::Comment, &ccomment.id.to_string()).to_string();
     Comment::update_ap_id(&conn, ccomment.id, apub_id)?;
   }
 
-  sql_query("alter table comment enable trigger refresh_comment").execute(conn)?;
-
   info!("{} comment rows updated.", incorrect_comments.len());
 
   Ok(())