python怎么將Dataframe格式的數(shù)據(jù)寫入opengauss數(shù)據(jù)庫(kù)并查詢

本文小編為大家詳細(xì)介紹“python怎么將Dataframe格式的數(shù)據(jù)寫入opengauss數(shù)據(jù)庫(kù)并查詢”，內(nèi)容詳細(xì)，步驟清晰，細(xì)節(jié)處理妥當(dāng)，希望這篇“python怎么將Dataframe格式的數(shù)據(jù)寫入opengauss數(shù)據(jù)庫(kù)并查詢”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來(lái)學(xué)習(xí)新知識(shí)吧。

一、將數(shù)據(jù)寫入opengauss

前提準(zhǔn)備：

成功opengauss數(shù)據(jù)庫(kù)，并創(chuàng)建用戶jack，創(chuàng)建數(shù)據(jù)庫(kù)datasets。

數(shù)據(jù)準(zhǔn)備：

所用數(shù)據(jù)以csv格式存在本地，編碼格式為GB2312。

數(shù)據(jù)存入：

開(kāi)始hello表未存在，那么執(zhí)行程序后，系統(tǒng)會(huì)自動(dòng)創(chuàng)建一個(gè)hello表（這里指定了名字為hello）；

若hello表已經(jīng)存在，那么會(huì)增加數(shù)據(jù)到hello表。列名需要與hello表一一對(duì)應(yīng)。

# 加載必要的python庫(kù)
from sqlalchemy import create_engine
import pandas as pd
 
# 從本地讀入數(shù)據(jù)
df = pd.read_csv("E:/jiema.csv",low_memory=False,encoding='gb2312')
 
#創(chuàng)建數(shù)據(jù)庫(kù)引擎
#create_engine說(shuō)明：driver://user:password@host:port/dbname
engine = create_engine('postgresql://jack:gauss@111@192.168.80.130:26000/datasets')
 
#寫入數(shù)據(jù)
try:
    df.to_sql('hello',engine,index=False,if_exists='append')  #hello為創(chuàng)建的數(shù)據(jù)庫(kù)表名字
except Exception as e:
    print(e)

使用navicat查看效果：

二、python條件查詢opengauss數(shù)據(jù)庫(kù)中文列名的數(shù)據(jù)

問(wèn)題：

由于項(xiàng)目要求，數(shù)據(jù)庫(kù)中的列名都是以中文命名的，導(dǎo)致在后期查詢的時(shí)候出現(xiàn)了很多問(wèn)題。

解決方法：

 整條SQL語(yǔ)句需要用單引號(hào)包裹，中文列名需要用雙引號(hào)包裹起來(lái)。

import psycopg2
 
def dataFromDB(sql):
    # 連接數(shù)據(jù)庫(kù)
    conn = psycopg2.connect(database='datasets', user='jack', password='gauss@111', host='192.168.80.130', port='26000')
    curs = conn.cursor()
 
    # 編寫Sql，只取前兩行數(shù)據(jù)
    # sql = 'select * from table_name limit 2'
 
    # 數(shù)據(jù)庫(kù)中執(zhí)行sql命令
    curs.execute(sql)
    # 獲得數(shù)據(jù)
    data = curs.fetchall()
    print(data)
 
    # 關(guān)閉指針和數(shù)據(jù)庫(kù)
    curs.close()
    conn.close()
 
sql ='SELECT "遙測(cè)參數(shù)2", "遙測(cè)參數(shù)2路溫度" from source2decode where "工程參數(shù).源地址" =26 '
 
dataFromDB(sql)

讀到這里，這篇“python怎么將Dataframe格式的數(shù)據(jù)寫入opengauss數(shù)據(jù)庫(kù)并查詢”文章已經(jīng)介紹完畢，想要掌握這篇文章的知識(shí)點(diǎn)還需要大家自己動(dòng)手實(shí)踐使用過(guò)才能領(lǐng)會(huì)，如果想了解更多相關(guān)內(nèi)容的文章，歡迎關(guān)注億速云行業(yè)資訊頻道。