python生成dataframe,python生成dataframe数据

  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的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: