commit every repeat with conn

cargo-paradedb/src/subcommand.rs

@@ -130,11 +130,11 @@ pub async fn insert_benchmark_corpus(glob: &str, table: &str, url: Option<&str>)
             .unwrap_or_else(|| std::env::var("DATABASE_URL").ok().unwrap_or_default()),
     )?;
     let mut conn = PgConnection::connect_with(&conn_opts).await?;
-    let mut transaction = sqlx::Connection::begin(&mut conn).await?;
+    // let mut transaction = sqlx::Connection::begin(&mut conn).await?;
 
     // Ensure the table exists;
     sqlx::query(&BenchLog::create_table_statement(table))
-        .execute(&mut *transaction)
+        .execute(&mut conn) // MAKE TRANSACTION
         .await?;
 
     // Read JSON data files, chunked to not overload Postgres.
@@ -145,12 +145,11 @@ pub async fn insert_benchmark_corpus(glob: &str, table: &str, url: Option<&str>)
         QueryBuilder::<Postgres>::new(BenchLog::insert_header(table))
             .push_values(chunk, BenchLog::insert_push_values)
             .build()
-            .execute(&mut *transaction)
+            .execute(&mut conn)
             .await?;
-
-        // Everything above happens in a single transaction, so all will
-        transaction.commit().await?;
     }
+    // // Everything above happens in a single transaction, so all will
+    // transaction.commit().await?;
 
     Ok(())
 }