快捷導(dǎo)航

python將Dataframe格式的數(shù)據(jù)寫(xiě)入opengauss數(shù)據(jù)庫(kù)并查詢(xún)

更新時(shí)間：2022年04月12日 18:28:36 作者：摸魚(yú)的胖七七

這篇文章主要介紹了python將Dataframe格式的數(shù)據(jù)寫(xiě)入opengauss數(shù)據(jù)庫(kù)并查詢(xún)，文章介紹詳細(xì)具有一定的參考價(jià)值，希望對(duì)你的學(xué)習(xí)有所幫助

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

前提準(zhǔn)備：

成功opengauss數(shù)據(jù)庫(kù)，并創(chuàng)建用戶(hù)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')
?
#寫(xiě)入數(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條件查詢(xún)opengauss數(shù)據(jù)庫(kù)中文列名的數(shù)據(jù)

問(wèn)題：

由于項(xiàng)目要求，數(shù)據(jù)庫(kù)中的列名都是以中文命名的，導(dǎo)致在后期查詢(xún)的時(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()
?
? ? # 編寫(xiě)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)

到此這篇關(guān)于python將Dataframe格式的數(shù)據(jù)寫(xiě)入opengauss數(shù)據(jù)庫(kù)并查詢(xún)的文章就介紹到這了,更多相關(guān)python將數(shù)據(jù)寫(xiě)入opengauss內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: