(&mut self, table_id: &Self::TableId, rows: Vec<T>)
| 114 | } |
| 115 | |
| 116 | fn insert_bulk<T: BenchTable>(&mut self, table_id: &Self::TableId, rows: Vec<T>) -> ResultBench<()> { |
| 117 | let statement = memo_query(BenchName::InsertBulk, table_id, || { |
| 118 | insert_template(table_id, T::product_type()) |
| 119 | }); |
| 120 | |
| 121 | let mut begin: rusqlite::CachedStatement<'_> = self.db.prepare_cached(BEGIN_TRANSACTION)?; |
| 122 | let mut stmt = self.db.prepare_cached(&statement)?; |
| 123 | let mut commit = self.db.prepare_cached(COMMIT_TRANSACTION)?; |
| 124 | |
| 125 | begin.execute(())?; |
| 126 | for row in rows { |
| 127 | stmt.execute(row.into_sqlite_params())?; |
| 128 | } |
| 129 | commit.execute(())?; |
| 130 | |
| 131 | Ok(()) |
| 132 | } |
| 133 | |
| 134 | fn update_bulk<T: BenchTable>(&mut self, table_id: &Self::TableId, row_count: u32) -> ResultBench<()> { |
| 135 | let mut product = T::product_type(); |
no test coverage detected