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.安裝完畢後,將客戶...