Execute SQL statement inserting data Parameters ---------- conn : sqlalchemy.engine.Engine or sqlalchemy.engine.Connection keys : list of str Column names data_iter : generator of list Each item contains a list of values to be i
(self, conn, keys: list[str], data_iter)
| 999 | self._execute_create() |
| 1000 | |
| 1001 | def _execute_insert(self, conn, keys: list[str], data_iter) -> int: |
| 1002 | """ |
| 1003 | Execute SQL statement inserting data |
| 1004 | |
| 1005 | Parameters |
| 1006 | ---------- |
| 1007 | conn : sqlalchemy.engine.Engine or sqlalchemy.engine.Connection |
| 1008 | keys : list of str |
| 1009 | Column names |
| 1010 | data_iter : generator of list |
| 1011 | Each item contains a list of values to be inserted |
| 1012 | """ |
| 1013 | data = [dict(zip(keys, row, strict=True)) for row in data_iter] |
| 1014 | result = self.pd_sql.execute(self.table.insert(), data) |
| 1015 | return result.rowcount |
| 1016 | |
| 1017 | def _execute_insert_multi(self, conn, keys: list[str], data_iter) -> int: |
| 1018 | """ |