Change some code

rikonaka · Jul 6, 2023 · 18c1c90 · 18c1c90
1 parent ec6b582
commit 18c1c90
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 9 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -209,7 +209,7 @@ impl SQLite {
         match self.alive {
             true => {
                 let rows = sqlx::query(sql).fetch_all(&mut self.connection).await?;
-                sqlite::raw_process(rows).await
+                sqlite::row_process(rows).await
             }
             false => panic!("{}", CLOSED_CONNECTION_ERROR),
         }
@@ -220,7 +220,7 @@ impl SQLite {
             true => {
                 let row = sqlx::query(sql).fetch_one(&mut self.connection).await?;
                 let rows = vec![row];
-                sqlite::raw_process(rows).await
+                sqlite::row_process(rows).await
             }
             false => panic!("{}", CLOSED_CONNECTION_ERROR),
         }
@@ -303,7 +303,7 @@ impl MySQL {
         match self.alive {
             true => {
                 let rows = sqlx::query(sql).fetch_all(&mut self.connection).await?;
-                mysql::raw_process(rows).await
+                mysql::row_process(rows).await
             }
             false => panic!("{}", CLOSED_CONNECTION_ERROR),
         }
@@ -314,7 +314,7 @@ impl MySQL {
             true => {
                 let row = sqlx::query(sql).fetch_one(&mut self.connection).await?;
                 let rows = vec![row];
-                mysql::raw_process(rows).await
+                mysql::row_process(rows).await
             }
             false => panic!("{}", CLOSED_CONNECTION_ERROR),
         }
@@ -386,7 +386,7 @@ impl PostgreSQL {
         match self.alive {
             true => {
                 let rows = sqlx::query(sql).fetch_all(&mut self.connection).await?;
-                postgresql::raw_process(rows).await
+                postgresql::row_process(rows).await
             }
             false => panic!("{}", CLOSED_CONNECTION_ERROR),
         }
@@ -397,7 +397,7 @@ impl PostgreSQL {
             true => {
                 let row = sqlx::query(sql).fetch_one(&mut self.connection).await?;
                 let rows = vec![row];
-                postgresql::raw_process(rows).await
+                postgresql::row_process(rows).await
             }
             false => panic!("{}", CLOSED_CONNECTION_ERROR),
         }

diff --git a/src/mysql.rs b/src/mysql.rs
@@ -63,7 +63,7 @@ impl fmt::Display for MySQLDataTypes {
     }
 }
 
-pub async fn raw_process(rows: Vec<MySqlRow>) -> anyhow::Result<SQLRets> {
+pub async fn row_process(rows: Vec<MySqlRow>) -> anyhow::Result<SQLRets> {
     let mut sql_rets = SQLRets::new();
 
     if rows.len() > 0 {

diff --git a/src/postgresql.rs b/src/postgresql.rs
@@ -100,7 +100,7 @@ impl fmt::Display for PostgreSQLDataTypes {
     }
 }
 
-pub async fn raw_process(rows: Vec<PgRow>) -> anyhow::Result<SQLRets> {
+pub async fn row_process(rows: Vec<PgRow>) -> anyhow::Result<SQLRets> {
     let mut sql_rets = SQLRets::new();
 
     if rows.len() > 0 {

diff --git a/src/sqlite.rs b/src/sqlite.rs
@@ -42,7 +42,7 @@ impl fmt::Display for SQLiteDataTypes {
     }
 }
 
-pub async fn raw_process(rows: Vec<SqliteRow>) -> anyhow::Result<SQLRets> {
+pub async fn row_process(rows: Vec<SqliteRow>) -> anyhow::Result<SQLRets> {
     let mut sql_rets = SQLRets::new();
 
     if rows.len() > 0 {