python生成dataframe,python生成dataframe数据
本文主要介绍python将Dataframe格式的数据写入opengauss数据库并进行查询。文章的详细介绍有一定的参考价值,希望对你的学习有所帮助。
00-1010 1.将数据写入opengauss 2。在python条件下查询opengauss数据库中的中文列名数据。
目录
前提准备:
成功打开gauss数据库,创建用户jack,并创建数据库数据集。
数据准备:
使用的数据以csv格式存在于本地,编码格式为GB2312。
数据存入:
开始hello表不存在,那么程序执行后,系统会自动创建一个hello表(此处名称为hello);
如果hello表已经存在,数据将被添加到hello表中。列名需要与hello表一一对应。
#加载必要的python库
从sqlalchemy导入创建引擎
进口熊猫作为pd
#本地读入数据
df=PD . read _ CSV( e :/jiema . CSV ,low_memory=False,encoding=gb2312 )
#创建数据库引擎
#create_engine描述:driver ://user 3360 password @ host 3360 port/dbname
engine=create _ engine( PostgreSQL ://jack : gauss @ 111 @ 192 . 168 . 80/datasets )
#写入数据
尝试:
Df.to _ SQL (hello ,engine,index=false,if _ exists= append) # hello是创建的数据库表的名称。
e:除外
打印(e)
使用navicat查看效果:
一、将数据写入opengauss
问题:
由于项目的要求,数据库中的所有列都是用中文命名的,导致后期查询时出现很多问题。
解决方法:
整个SQL语句需要用单引号括起来,中文列名需要用双引号括起来。
导入psycopg2
def dataFromDB(sql):
#连接到数据库
conn=psycopg2.connect(数据库=数据集,用户=杰克,密码=高斯@111 ,主机=192.168.80.130 ,端口=26000 )
curs=conn.cursor()
#写Sql,只取前两行数据
# SQL= select * from table _ name limit 2
#在数据库中执行sql命令
游标. execute(sql)
#获取数据
data=curs.fetchall()
打印(数据)
#关闭指针和数据库
curs.close()
conn.close()
Sql=选择遥测参数2 ,遥测参数2通道温度来自source2decode where 工程参数。源地址=26
dataFromDB(sql)
关于python将Dataframe格式的数据写入opengauss数据库并对其进行查询的文章到此结束。关于python将数据写入opengauss的更多信息,请搜索热门IT软件开发工作室之前的文章或者继续浏览下面的相关文章。希望你以后能支持热门的IT软件开发工作室!
郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。