pandas 数据帧到PostgreSQL表中使用的是没有SQLAlChemy的心理复制2吗?

Pandas dataframe to PostgreSQL table using psycopg2 without SQLAlchemy?( pandas 数据帧到PostgreSQL表中使用的是没有SQLAlChemy的心理复制2吗?)
本文介绍了 pandas 数据帧到PostgreSQL表中使用的是没有SQLAlChemy的心理复制2吗?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我要将Pandas数据帧写入PostgreSQL表,而不使用SQLAlChemy

表名应与PANDAS变量名对应,如果已存在,则替换该表。数据类型也需要匹配。

出于几个原因,我希望避免使用SQLAlChemy的TO_SQL函数。

import pandas as pd
from getpass import getpass
import psycopg2

your_pass = getpass(prompt='Password: ', stream=None)
conn_cred = {
    'host': your_host,
    'port': your_port,
    'dbname': your_dbname,
    'user': your_user,
    'password': your_pass
}
conn = psycopg2.connect(**conn_cred)
conn.autocommit = True

my_data = {'col1': [1, 2], 'col2': [3, 4]}

def store_dataframe_to_postgre(df, schema, active_conn):
    # df = pandas dataframe to store as a table
    # schema = schema for the table
    # active_conn = open connection to a PostgreSQL db
    # ...
    # Bonus: require explicit commit here, even though conn.autocommit = True


store_dataframe_to_postgre(my_data, 'my_schema', conn)

这应该是postgre数据库中的结果:

SELECT * FROM my_schema.my_data;
   col1  col2
     1     3
     2     4

推荐答案

您可以尝试,但以下代码位于您的:

 cursor = conn.cursor()  
 cur.copy_from(df, schema , null='', sep=',', columns=(my_data))
参考代码: copy dataframe to postgres table with column that has defalut value

这篇关于 pandas 数据帧到PostgreSQL表中使用的是没有SQLAlChemy的心理复制2吗?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Leetcode 234: Palindrome LinkedList(Leetcode 234:回文链接列表)
How do I read an Excel file directly from Dropbox#39;s API using pandas.read_excel()?(如何使用PANDAS.READ_EXCEL()直接从Dropbox的API读取Excel文件?)
subprocess.Popen tries to write to nonexistent pipe(子进程。打开尝试写入不存在的管道)
I want to realize Popen-code from Windows to Linux:(我想实现从Windows到Linux的POpen-code:)
Reading stdout from a subprocess in real time(实时读取子进程中的标准输出)
How to call type safely on a random file in Python?(如何在Python中安全地调用随机文件上的类型?)