python - 无法写入 Snowflake 表但没有返回错误

Question

代码运行成功，没有返回错误，但只显示旧记录:

import pandas as pd
from sqlalchemy import create_engine
from snowflake.sqlalchemy import URL
from config import config

engine = create_engine(URL(account=config.account, 
          user=config.username, 
          password=config.password, 
          warehouse=config.warehouse, 
          database=config.database, 
          schema=config.schema,))
    
conn = engine.connect()
    
df = pd.DataFrame([('AAA', '1234'), ('BBB', '5678')], columns=['name', 'pswd'])
df.to_sql('demo_db.public.test_f1', con=engine, index=False, if_exists='append', index_label=None)
        
df = pd.read_sql_query('select * from demo_db.public.test_f1', conn)
print(df.head(5))
    
conn.close()
engine.dispose()

请帮忙!

Answer 1

似乎 3 部分名称被视为单个标识符，数据被插入到名为 "demo_db.public.test_f1" 的表中。 :

SELECT * FROM demo_db.public."demo_db.public.test_f1";

name只能作为表名提供，数据库/模式是从连接推断出来的:

df.to_sql('test_f1', con=engine, index=False, if_exists='append', index_label=None)