ON CONFLICT statement: with engine.begin () as conn: # step 0.0 - create test environment conn.execute (sa.text ("DROP TABLE IF EXISTS main_table")) conn.execute ( sa.text ( "CREATE TABLE main_table (id int primary key, txt varchar (50 . You can use 'replace', 'append' to replace it. How to fix pandas to_sql() AttributeError: 'DataFrame' object has no ... As I use engine from sqlmodel which has SQLAlchemy 2.0 underneath. A Fast Method to Bulk Insert a Pandas DataFrame into Postgres I am new using pandas. Finally, we execute commands using the execute () method to execute our SQL commands and fetchall () method to fetch the records. Column label for index column (s). 清空表操作：truncate table xxx; 然后再使用：append 的 to_sql. Note that if data is a pandas DataFrame, a Spark DataFrame, and a pandas-on-Spark Series, other arguments should not be used. For this first example, as promised, we use the following one line of code: df.to_sql ('Expenses', con=conn, if_exists='append', index=False) Here, we passed "Expenses" as the name of the table in the SQLite database we want to write to. Photo by Mika Baumeister on Unsplash. We can now easily query it to extract only those columns that we require; for instance, we can extract only those rows where the passenger count is less than 5 and the trip distance is greater than 10. pandas.read_sql_queryreads SQL query into a DataFrame. in case failed name matching the ISERT might have to fail and signal, that programcode has to be adapted. Also I'm not sure about This InternalError: (psycopg2.errors.InFailedSqlTransaction) current transaction is aborted, commands ignored until end of transaction block when connection object tries to execute . Alternatively, we can use "pandas.DataFrame.to_sql" with an option of " if_exists='append' " to bulk insert rows to a SQL database. How to fix pandas to_sql() AttributeError: 'DataFrame' object has no ...