cx_Oracle使用方法二

下載地址：

https://pypi.python.org/pypi/cx_Oracle/5.2.1, 下載的時候注意數據庫版本和操作系統環境。

技術手冊：

http://cx-oracle.readthedocs.org/en/latest/index.html

cx_Oracle使用方法

正確安裝好cx_oracle之后，要使用它來連接到oracle數據庫進行操作，具體應該分3步走：

第一步：導入cx_Oracle ，建立連接

>>> import cx_Oracle      # 導入模塊 
>>> db = cx_Oracle.connect('hr', 'hrpwd', 'localhost:1521/XE') #建立連接，3 個參數分開寫
>>> db1 = cx_Oracle.connect('hr/hrpwd@localhost:1521/XE') #建立連接，3 個參數連寫
>>> dsn_tns = cx_Oracle.makedsn('localhost', 1521, 'XE')
>>> print dsn_tns 
(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=localhost)(PORT=1521)))(CONNECT_DATA=(SID=XE)))
>>> db2 = cx_Oracle.connect('hr', 'hrpwd', dsn_tns)
>>> print db.version
10.2.0.1.0
>>> versioning = db.version.split('.')
>>> print versioning
['10', '2', '0', '1', '0']
>>> if versioning[0]=='10':
...      print "Running 10g"
... elif versioning[0]=='9':
...      print "Running 9i"
...
Running 10g
>>> print db.dsn
localhost:1521/XE

第二步：建立 Cursor 光標

>>>cursor = db.cursor() 
#建立一個cursor之后，我們可以調用這個cursor.execute（‘SQL‘） 來執行SQL語句。比如：
>>>cursor.execute(‘select * from tabs’)
#執行完畢以后，可以調用cursor.fetchall()一次取完所有結果，或者cursor.fetchone()一次取一行結果
>>> row=cursor.fetchall()
>>> for x in row:
        For y in x:
            Print y,
        Print

    

這樣就可以按照表格的形式打印取得的結果了！

在從oracle取出數據的時候，考慮到它的數據類型了嗎？下面就是數據類型的對應表

Datatypes

During the fetch stage, basic Oracle data types get mapped into their Python equivalents. cx_Oracle maintains a separate set of data types that helps in this transition. The Oracle - cx_Oracle - Python mappings are:

 

Oracle	cx_Oracle	Python
VARCHAR2 NVARCHAR2 LONG	cx_Oracle.STRING	str
CHAR	cx_Oracle.FIXED_CHAR
NUMBER	cx_Oracle.NUMBER	int
FLOAT		float
DATE	cx_Oracle.DATETIME	datetime.datetime
TIMESTAMP	cx_Oracle.TIMESTAMP
CLOB	cx_Oracle.CLOB	cx_Oracle.LOB
BLOB	cx_Oracle.BLOB

 

帶參數的查詢：

>>> named_params = {'dept_id':50, 'sal':1000}
>>> query1 = cursor.execute('SELECT * FROM employees WHERE department_id=:dept_id AND salary>:sal', named_params)
>>> query2 = cursor.execute('SELECT * FROM employees WHERE department_id=:dept_id AND salary>:sal', dept_id=50, sal=1000)

這種是名字參數，還可以按位置參數：

r1 = cursor.execute('SELECT * FROM locations WHERE country_id=:1 AND city=:2', ('US', 'Seattle'))

注意：

當只有一次參數的時候，也要把它寫成元組的形式，比如

Cursor.execute(‘select name from user where id=:1’,(login_Id,))

千萬要注意，login_id后面還帶有一個逗號，如果沒有逗號，他其實就是一個數據對象，但是當他后面有個逗號的時候，他就變成了元組的一個數據項，千萬要記住啊，我就是在這里徘徊了很久。！

Cursor. Prepare的用法，

這個方法就是在prepare之后，你再去execute的時候，就不用寫上sql語句參數了

>>> cursor.prepare('SELECT * FROM jobs WHERE min_salary>:min')
>>> r = cursor.execute(None, {'min':1000}) #注意，第一個參數是None

一次執行多條sql語句：
Large insert operations don't require many separate inserts because Python fully supports inserting many rows at once with the cx_Oracle.Cursor.executemany method. Limiting the number of execute operations improves program performance a lot and should be the first thing to think about when writing applications heavy on INSERTs.
Let's create a table for a Python module list, this time directly from Python. You will drop it later.

>>> create_table = """
CREATE TABLE python_modules (
module_name VARCHAR2(50) NOT NULL,
file_path VARCHAR2(300) NOT NULL
)
"""
>>> from sys import modules
>>> cursor.execute(create_table)
>>> M = []
>>> for m_name, m_info in modules.items():
...     try:
...       M.append((m_name, m_info.__file__))
...     except AttributeError:
...       pass
...
>>> len(M)
76
>>> cursor.prepare("INSERT INTO python_modules(module_name, file_path) VALUES (:1, :2)")
>>> cursor.executemany(None, M)
>>> db.commit()
>>> r = cursor.execute("SELECT COUNT(*) FROM python_modules")
>>> print cursor.fetchone()
(76,)
>>> cursor.execute("DROP TABLE python_modules PURGE")

 BLOB & CLOB 格式的創建:

binary_content = cursor.var(cx_Oracle.BLOB)
binary_content.setvalue(0, content)