(self)
| 983 | self.table.create(bind=self.pd_sql.con) |
| 984 | |
| 985 | def create(self) -> None: |
| 986 | if self.exists(): |
| 987 | if self.if_exists == "fail": |
| 988 | raise ValueError(f"Table '{self.name}' already exists.") |
| 989 | elif self.if_exists == "replace": |
| 990 | self.pd_sql.drop_table(self.name, self.schema) |
| 991 | self._execute_create() |
| 992 | elif self.if_exists == "append": |
| 993 | pass |
| 994 | elif self.if_exists == "delete_rows": |
| 995 | self.pd_sql.delete_rows(self.name, self.schema) |
| 996 | else: |
| 997 | raise ValueError(f"'{self.if_exists}' is not valid for if_exists") |
| 998 | else: |
| 999 | self._execute_create() |
| 1000 | |
| 1001 | def _execute_insert(self, conn, keys: list[str], data_iter) -> int: |
| 1002 | """ |
no test coverage detected