pandas-to-sql相关内容
我想将一个大的 pandas.DataFrame 发送到运行 MS SQL 的远程服务器.我现在这样做的方法是将 data_frame 对象转换为元组列表,然后使用 pyODBC 的 executemany() 函数将其发送出去.它是这样的: 将 pyodbc 导入为 pdblist_of_tuples = convert_df(data_frame)连接 = pdb.connect(cnxn
..
我正在尝试将 pyodbc 连接切换到 sqlalchemy.工作 pyodbc 连接是: 导入pyodbccon = 'DRIVER={ODBC Driver 11 for SQL Server};SERVER=server.com\pro;DATABASE=DBase;Trusted_Connection=yes'cnxn = pyodbc.connect(con)游标 = cnxn.cur
..
我有一个关于如何将数据框保存到本地 mysql 的问题. 导入 MySQLdb将熊猫导入为 pdconn=MySQLdb.connect(host="localhost",user='root',passwd="matt123",db="ada")df=pd.DataFrame(['A','B'],columns=['new_tablecol'])df.to_sql(name='new_tabl
..
嗨,我正在尝试使用df.to_sql将数据帧写入我的sql数据库,但是却收到错误消息:TypeError:无法在类似字节的对象上使用字符串模式.我正在使用Python 3. 我在驱动器上使用了一条我无法共享的路径.但是当我只想使用打开csv文件时,它可以正常工作. df = pd.read_csv(path,delimiter =';',engine ='python',low_memory
..
我的问题本质上是这样的:当我尝试将to_sql与if_exists ='append'一起使用,并且将名称设置为SQL Server上已经存在python崩溃的表时. 这是我的代码: @event.listens_for(engine, 'before_cursor_execute') def receive_before_cursor_execute(conn, cursor, st
..
我正在尝试将数据帧写入MySQL表,但出现(111 Connection refused)错误. 我在这里遵循了公认的答案: 使用SQLAlchemy,to_sql和熊猫一起写入MySQL数据库 答案的代码: import pandas as pd import mysql.connector from sqlalchemy import create_engine engin
..
我有以下数据框 ipdb> csv_data country sale date trans_factor 0 India 403171 12/01/2012 1 1 Bhutan 394096 12/01/2012 2 2 Nepal super 12/01/2012
..
我正在尝试连接到Teradata服务器,并使用python将数据帧加载到表中.这是我的代码- import sqlalchemy engine = sqlalchemy.create_engine("teradata://username:passwor@hostname:port/") f3.to_sql(con=engine, name='sample', if_exists='r
..
我想向运行MS SQL的远程服务器发送大型pandas.DataFrame.我现在的方法是将data_frame对象转换为元组列表,然后使用pyODBC的executemany()函数将其发送出去.它是这样的: import pyodbc as pdb list_of_tuples = convert_df(data_frame) connection = pdb.connect(
..
Dask没有像pandas这样的df.to_sql(),因此我正尝试复制功能并使用map_partitions方法创建sql表.这是我的代码: import dask.dataframe as dd import pandas as pd import sqlalchemy_utils as sqla_utils db_url = 'my_db_url_connection' conn =
..
接着从IntegrityError: (psycopg2.IntegrityError) duplicate key value violates unique constraint "pg_type_typname_nsp_index" DETAIL: Key (typname, typnamespace)=(test1, 2200) already exists. [SQL: '\nCREAT
..
如何使用df.to_sql(if_exists = 'append')在数据框和数据库之间仅附加唯一值.换句话说,我想评估DF和DB之间的重复项,并在写入数据库之前删除这些重复项. 是否有用于此的参数? 我知道参数if_exists = 'append'和if_exists = 'replace'用于整个表-而不是唯一条目. I am using: sqlalchemy pa
..
我是一名新的oracle学习者.我正在尝试将pandas数据框写入到oracle表中.在网上进行研究之后,我发现代码本身非常简单,但是我不知道为什么我的代码不起作用. 我已经从本地文件中读取了熊猫数据框: import cx_Oracle import pandas as pd import os dir_path = os.path.dirname(os.path.realpath
..