python中cx Oracle的操作

2021-06-18 08:10:01 字數 1313 閱讀 4493

def oracle_connect_cursor():

'''oracle_connect_cursor

'''dsn_tns = cx_oracle.makedsn(ip, port,資料庫名 )

connection = cx_oracle.connect(使用者名稱, 密碼, dsn_tns)

cursor = connection.cursor()

return cursor

def execute_sql(scommand):

'''execute_sql

'''

db =oracle_connect_cursor()

db.execute(scommand)

if 'select' not in scommand[6]:

db.execute('commit')

if 'select' in scommand[6]:

sresult = db.fetchall()

print sresult

# if did not get and value, it will return none

# if not len(sresult):

if not sresult: # if the sresult is empty, the sresult's value is false

sresult = none

return sresult

以上**中設定了檢查傳進來的命令的前6個字母是不是select,如果是select 則返回查詢結果,否則操作完了就提交。將上述**插入到你的**後,可以採用如下方式引用:

scommand=('update table_name set key=key-120 where name=\'%s\'' %var1)

execute_sql(scommand)

這段**是更新資料庫的**。就是將table_name 中name等於var1的key值減少120

而這個過程中可以直接引用 execute_sql(scommand) 來操作,是不是很簡單啊?

下面再看看查詢的例子

scommand=('select key from table_name where name=\'%s\'' %var1)

key_value=execute_sql(scommand)

print type(key_value)

來檢視一下吧,然後我想你就知道怎麼操作了。

Python操作cx Oracle筆記

參考文章 建立資料庫連線 ordb oracle.connect format user,password,db ip,str port service name encoding utf 8 建立游標,返回乙個游標物件 ordb.cursor 測試指令碼常用 api cursor.execute ...

Python原始碼安裝cx Oracle

最近需要將hive中的資料匯入到oracle,採用了通過pyspark讀取hive資料,然後通過python連線資料庫,將資料插入到oracle的方案。所以涉及到了cx orcacle的安裝部署。現將涉及到的包上傳到了 1 cx oracle 2 oracle client 使用cx oracle必...

python 安裝cx oracle注意事項

1.環境 作業系統 win7 64位 資料庫 oralce 11g python版本 3.4 2.安裝事項 1.oracle 客戶端 ox oracle版本必須跟作業系統位數一樣,即都是64位。如果不一致,當執行import ox oracle的時候報 不是win32程式錯誤 2.安裝完畢後,將客戶...