时间戳

首页 > 解决方案 > 使用 python(cx_oracle) 连接到 oracle 数据库

python - 使用 python(cx_oracle) 连接到 oracle 数据库

问题描述

我正在尝试在 python 中使用 cx_Oracle 连接到 oracle 数据库。我能够连接到数据库并提取数据。

现在我正在尝试连接到另一个数据库，我必须首先调用一个安全过程，然后我才能看到基础表中的数据。您能否通过调整以下代码块来帮助我调用该程序。我的程序将是： exec ef.applogin('1234')

def connect_oracle():
    import cx_Oracle
    import pandas as pd
    ip = 'some_ip'
    port = 1521
    SID = 'some_SID'
    dsn_tns = cx_Oracle.makedsn(ip, port, SID)
    connection = cx_Oracle.connect('user_name', 'password', dsn_tns)
    #Procedure to be executed here..    
    query = """ SELECT * from table_name """
    df_ora = pd.read_sql(query, con=connection)
    return df_ora

connect_oracle()

提前谢谢了！！

标签： pythonoraclecx-oracle

解决方案

由 Oracle 为连接创建 def。对于执行过程使用游标。不要忘记关闭连接和光标。也以防万一。

import cx_Oracle
import pandas as pd

ip = 'some_ip'
port = 1521
SID = 'some_SID'
user_name = 'user_name'
password = 'password'
query = """ SELECT * from table_name """

def connect_oracle(ip, port, SID, user_name, password):
    dsn_tns = cx_Oracle.makedsn(ip, port, SID)
    connection = cx_Oracle.connect(user_name, password, dsn_tns)
    return connection

def get_df(conn, query):
    df_ora = pd.read_sql(query, con=conn)
    return df_ora


def execute_proc(conn, procname, param):    
    my_cursor=conn.cursor()
    my_cursor.callproc(procname, param)
    conn.commit()

def execute_func(conn, procname, param):    
    my_cursor=conn.cursor()
    out_parameter = my_cursor.var(cx_Oracle.NUMBER)
    qw = my_cursor.callfunc(procname, out_parameter)
    return qw

conn1 = connect_oracle(ip, port, SID, user_name, password)
df = get_df(conn1, query)
df.head()
execute_proc(conn1, "insert_temp", [])
execute_func(conn1, "get_version", [])

测试功能：

create or replace function get_version
return number
is
    v_version NUMBER(8) := 11;
begin
    return v_version;
end;

测试程序：

create table temp (clm number);
create or replace procedure insert_temp
is
    v_version NUMBER(8) := 11;
begin
    insert into temp(clm) values(v_version);
end;
select *  from temp

推荐阅读