1. 连接对象
操作数据库之前,首先要建立数据库连接。
有下面几个方法进行连接。
>>>import cx_Oracle>>>db = cx_Oracle.connect('hr', 'hrpwd', 'localhost:1521/XE')>>>db1 = cx_Oracle.connect('hr/hrpwd@localhost:1521/XE')>>>dsn_tns = cx_Oracle.makedsn('localhost', 1521, 'XE')>>>print dsn_tns >>>print db.version10.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.dsnlocalhost:1521/XE
2. cursor对象
使用数据库连接对象的cursor()方法,你可以定义任意数量的cursor对象,简单的程序可能使用一个cursor,并重复使用了,但大型项目会使用多个不同的cursor。
>>>cursor= db.cursor()
应用程序逻辑通常需要清楚的区分处理数据操作的每个阶段。这将帮助更好的理解性能瓶颈和代码优化。
这些步骤有:
parse(optional)
无需调用该方法,因为执行阶段会自动先执行,用于检查sql语句是否正确,当有错误时,抛出DatabaseError异常及相应的错误信息。如:‘'ORA-00900:invalid SQL statement.“。
Executecx_Oracle.Cursor.execute(statement,[parameters], **keyword_parameters)
该方法能接收单个参数SQL,直接操作数据库,也可以通过绑定变量执行动态SQL,parames或keyworparameters可以是字典、序列或一组关键字参数。
cx_Oracle.Cursor.executemany(statement,parameters)
特别有用的批量插入,避免一次只能插入一条;
Fetch(optional)
仅用于查询,因为DDL和DCL语句没有返回结果。如果cursor没有执行查询,会抛出InterfaceError异常。
cx_Oracle.Cursor.fetchall()
获取所有结果集,返回元祖列表,如果没有有效行,返回空列表。
cx_Oracle.Cursor.fetchmany([rows_no])
从数据库中取下一个rows_no数据
cx_Oracle.Cursor.fetchone()
从数据库中取单个元祖,如果没有有效数据返回none。
3. 绑定变量
绑定变量查询可以提高效率,避免不必要的编译;参数可以是名称参数或位置参数,尽量使用名称绑定。
>>>named_params = {'dept_id':50, 'sal':1000}>>>query1 = cursor.execute('SELECT * FROM employees WHERE department_id=:dept_idAND salary>:sal', named_params)>>> query2 = cursor.execute('SELECT * FROM employees WHERE department_id=:dept_idAND salary>:sal', dept_id=50, sal=1000)Whenusing named bind variables you can check the currently assigned ones using thebindnames() method of the cursor: >>> printcursor.bindnames() ['DEPT_ID', 'SAL']
新闻热点
疑难解答