您的位置:首页 > 编程语言 > Python开发

Python连接数据库

2017-12-11 11:36 477 查看
本次以连接oracle数据库为例

首先安装加载第三方模块:

cx_Oracle-6.0.2-cp36-cp36m-win_amd64 (windows环境)
cx_Oracle-6.0.2-cp35-cp35m-manylinux1_x86_64 (linux环境)


基本语法:

cx_Oracle.connect('username','pwd','IP/HOSTNAME:PORT/TNSNAME')


加载模块、定义函数

import pandas as pd
import cx_Oracle as co

def query(table,column):
username = "ods"
pwd = "1q2w3e"
dsn = co.makedsn('137.0.0.1','1521','sdedw')  #建立连接
conn = co.connect(username,pwd,dsn)
cursor = conn.cursor() #获取游标
cursor.execute(table)  #执行查询
rows = cursor.fetchall()  #获取数据,可以有多种方式 fetchall(),fetchmang(N)(N 为正整数),fetchone()
count = cursor.rowcount
print("=====================")
print("Total:", count)
print("=====================")
data = pd.DataFrame(rows,columns = column)
cursor.close
return data


读取数据

data = query("select * from temp_rwk_cnk_ls6",['SERV_ID','CUST_AGE','SERV_NEW_CUST_TYPE','SERVICE_LEVEL','ONLINE_LEN','BILLING_MODE_ID','BUILD_TYPE','SUB_TYPE','NUMBER_COUNT','NUMBER_COUNT_TREND','AGAIN_NET_IN_FLAG','OFFER_NAME','IS_XIEYI','ACCT_FEE','BALANCE'])

data = data.set_index('SERV_ID')  #指定索引
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: