python連線資料庫

python連線資料庫的方法：

一、利用sqlalchemy包連線資料庫

import os

import sys
import pandas as pd
import datetime
from sqlalchemy import create_engine #python運算元據庫法1
from string import template
#初始化引擎
engine=create_engine('postgresql+psycopg2://pg_username :pg_password@pg_host:pg_port/pg_database')
sql1="""select * from  $arg1 where is_fi ='1' limit 100 """
sql1=template(sql1)## template方法,初始化乙個字串，呼叫substitute或safe_subsititute，將key值與方法中傳遞過來的引數對應上
data=pd.read_sql_query(sql1.substitute(arg1='xx.dm_user_***x_202006'),engine)#利用pandas讀取資料,substitute指定字串的引數

import psycopg2 #python運算元據庫法2

#初始化
conn=psycopg2.connect(database="xx",user="xx",password="xx",host="xx",port="***x")
cursor=conn.cursor()
cursor.execute("select * from xx.dm_user_***x_202006 where is_fi ='1'limit 100") #執行語句
rows = cursor.fetchall()#將返回所有結果，返回二維元組;cursor.fetchone()：將只取最上面的第一條結果
data = pd.dataframe(rows)#轉化成資料框的格式

pd.io.sql.to_sql(data,'cx_rk',engine,schema='tmp',if_exists='replace',index=false) #資料匯入到資料庫

psycopg2是postgresql官方指定推薦包，對於postgresql來說，他是最合適的包；而sqlalchemy可以在很多態別的資料庫使用，包含postgresql；

python 連線資料庫

原文 原文1 安裝mysql python pip install mysql python dome1 def db mange db bank conn none try 開啟資料庫連線 conn mysqldb.connect localhost root 123456 db bank 獲取操...

Python連線資料庫

usr bin env python coding utf 8 import sys reload sys sys.setdefaultencoding utf 8 import pymysql import pymysql.cursors usr bin env python coding utf...

python連線資料庫

1 安裝mysql ubantu下安裝不撰述 2 安裝python版本的mysql開發包 sudo apt get install python mysqldb3 編寫python usr bin python coding utf 8 import mysqldb 引入mysqldb包 開啟資料庫...