Python连接数据库
发布日期:2021-06-30 22:33:23 浏览次数:2 分类:技术文章

本文共 1065 字,大约阅读时间需要 3 分钟。

本次以连接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 pdimport cx_Oracle as codef 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')  #指定索引

转载地址:https://lovebigdata.blog.csdn.net/article/details/78771052 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:彻底搞懂Python代码前几行声明是什么
下一篇:python拉格朗日插值(详细)

发表评论

最新留言

能坚持,总会有不一样的收获!
[***.219.124.196]2024年05月02日 06时22分01秒