游标是SQL的一个内存工作区,由系统或用户以变量的形式定义。游标的作用就是用于临时存储从数据库中提取的数据块。Oracle数据库的Cursor类型包含三种: 静态游标:分为显式(explicit)游标和隐式(implicit)游标;REF游标:是一种引用类型,类似于指针。下面我们一一介绍它们的使用。
1.隐式游标
1)Select …INTO…语句,DML语句,使用隐式Cursor。此外,还有一种使用FOR LOOP的Implicit Cursor用法。
2)可以通过隐式Cusor的属性来了解 *** 作的状态和结果。Cursor的属性包含:
SQL%ROWCOUNT 整型代表DML语句成功执行的数据行数。
SQL%FOUND 布尔型值为TRUE代表插入、删除、更新或单行查询 *** 作成功。
SQL%NOTFOUND 布尔型与SQL%FOUND属性返回值相反。
SQL%ISOPEN 布尔型DML执行过程中为真,结束后为假。
3) 隐式Cursor由系统自动打开和关闭.
例如:
setserveroutputon
declare
begin
updateemployeessetemployee_name='Mike'whereemployee_id=1001
ifSQL%FOUNDthen
dbms_output.put_line('Nameisupdated')
else
dbms_output.put_line('Nameisnotupdated')
endif
end
/
setserveroutputon
declare
begin
fortableInfoin(select*fromuser_tables)loop
dbms_output.put_line(tableInfo.table_name)
endloop
exception
whenothersthen
dbms_output.put_line(sqlerrm)
end
/
2.显式游标
1) 显式Cursor的属性包含:
游标的属性 返回值类型 意义
%ROWCOUNT 整型 获得FETCH语句返回的数据行数
%FOUND 布尔型 最近的FETCH语句返回一行数据则为真,否则为假
%NOTFOUND 布尔型 与%FOUND属性返回值相反
%ISOPEN 布尔型 游标已经打开时值为真,否则为假
2) 对于显式游标的运用分为四个步骤:
a 定义游标---Cursor [Cursor Name] IS
b 打开游标---Open [Cursor Name]
c *** 作数据---Fetch [Cursor name]
d 关闭游标---Close [Cursor Name]
以下是几种常见显式Cursor用法。
<p>setserveroutputon
declare
cursorcurisselect*fromuser_tables
tableInfouser_tables%rowtype
begin
opencur
loop
fetchcurintotableInfo
exitwhencur%notfound
dbms_output.put_line(tableInfo.table_name)
endloop</p><p>exception
whenothersthen
dbms_output.put_line(sqlerrm)</p><p>closecur
end
/</p>
setserveroutputon
declare
cursorcurisselect*fromuser_tables
begin
fortableInfoincurloop
dbms_output.put_line(tableInfo.table_name)
endloop
exception
whenothersthen
dbms_output.put_line(sqlerrm)
end
/
还可以使用带参数open的cursor。
<p>setserveroutputon
declare
cursorcur(tblNamevarchar2)isselect*fromuser_constraintswheretable_name=tblName
tableInfouser_constraints%rowtype
begin
opencur('EMPLOYEES')
loop
fetchcurintotableInfo
exitwhencur%notfound
dbms_output.put_line(tableInfo.constraint_name)
endloop</p><p>exception
whenothersthen
dbms_output.put_line(sqlerrm)</p><p>closecur
end
/</p><p></p>
setserveroutputon
declare
cursorcur(tblNamevarchar2)isselect*fromuser_constraintswheretable_name=tblName
begin
fortableInfoincur('EMPLOYEES')loop
dbms_output.put_line(tableInfo.constraint_name)
endloop
exception
whenothersthen
dbms_output.put_line(sqlerrm)
end
/
可以使用WHERE CURRENT OF子句执行UPDATE或DELETE *** 作。
setserveroutputon
declare
cursorcurisselect*fromemployeesforupdate
begin
fortableInfoincurloop
updateemployeessetsalarysalary=salary*1.1wherecurrentofcur
endloop
commit
exception
whenothersthen
dbms_output.put_line(sqlerrm)
end
/
3.REF CURSOR(Cursor Variables)
REF Cursor在运行的时候才能确定游标使用的查询。利用REF CURSOR,可以在程序间传递结果集(一个程序里打开游标变量,在另外的程序里处理数据)。
也可以利用REF CURSOR实现BULK SQL,提高SQL性能。
REF CURSOR分两种,Strong REF CURSOR 和 Weak REF CURSOR。
Strong REF CURSOR:指定retrun type,CURSOR变量的类型必须和return type一致。
Weak REF CURSOR:不指定return type,能和任何类型的CURSOR变量匹配。
Ref cursor的使用:
1) Type [Cursor type name] is ref cursor
2) Open cursor for...
3) Fetch [Cursor name]
4) Close Cursor
例如:
Step1:
createorreplacepackageTESTas
typeemployees_refcursor_typeisrefcursorreturnemployees%rowtype
procedureemployees_loop(employees_curINemployees_refcursor_type)
endTEST
/
Step2:
createorreplacepackagebodyTESTas
procedureemployees_loop(employees_curINemployees_refcursor_type)is
empemployees%rowtype
begin
loop
fetchemployees_curintoemp
exitwhenemployees_cur%NOTFOUND
dbms_output.put_line(emp.employee_id)
endloop
endemployees_loop
endTEST
/
Step3:
setserveroutputon
declare
empRefCurTEST.employees_refcursor_type
begin
foriin10..20loop
dbms_output.put_line('DepartmentID='||i)
openempRefCurforselect*fromemployeeswheredepartment_id=i
TEST.employees_loop(empRefCur)
endloop
exception
whenothersthen
dbms_output.put_line(sqlerrm)
closeempRefCur
end
/
4.BULK SQL
使用FORALL和BULK COLLECT子句。利用BULK SQL可以减少PLSQL Engine和SQL Engine之间的通信开销,提高性能。
1. To speed up INSERT, UPDATE, and DELETE statements, enclose the SQL statement within a PL/SQL FORALL statement instead of a loop construct. 加速INSERT, UPDATE, DELETE语句的执行,也就是用FORALL语句来替代循环语句。
2. To speed up SELECT statements, include the BULK COLLECT INTO clause in the SELECT statement instead of using INTO. 加速SELECT,用BULK COLLECT INTO 来替代INTO。
SQL>createtableemployees_tmpasselectfirst_name,last_name,salaryfromemployeeswhere0=1
setserveroutputon
declare
cursoremployees_cur(depIdemployees.department_id%type)isselectfirst_name,last_name,salaryfromemployeeswheredepartment_id=depId
typeemployee_table_typeistableofemployees_cur%rowtypeindexbypls_integer
employee_tableemployee_table_type
begin
openemployees_cur(100)
fetchemployees_curbulkcollectintoemployee_table
closeemployees_cur
foriin1..employee_table.countloop
dbms_output.put_line(employee_table(i).first_name||''||employee_table(i).last_name||','||employee_table(i).salary)
endloop
foralliinemployee_table.first..employee_table.last
insertintoemployees_tmpvalues(employee_table(i).first_name,employee_table(i).last_name,employee_table(i).salary)
commit
end
/
太奇怪了,有时能获取数据,有时获取不了数据,把sql单独执行可以正常获取数据,测试了许久一直解决不了问题。后来看到了一句话,知道问题所在。多次使用cursor.fetchall(),会导致获取不到数据,cursor.fetchall()会把所有数据获取完,当再次调用cursor.fetchall()获取数据时,存在获取不到数据的可能。解决方法:把cursor.fetchall()替换为cursor.fetchone()。MySQLdb.connect是python 连接MySQL数据库的方法,在Python中 import MySQLdb即可使用,至于connect中的参数很简单:\x0d\x0ahost:MySQL服务器名\x0d\x0auser:数据库使用者\x0d\x0apassword:用户登录密码\x0d\x0adb: *** 作的数据库名\x0d\x0acharset:使用的字符集(一般是gb2312)\x0d\x0acursor = db.cursor() 其实就是用来获得python执行Mysql命令的方法,也就是\x0d\x0a我们所说的 *** 作游标\x0d\x0a下面cursor.execute则是真正执行MySQL语句,即查询TABLE_PARAMS表的数据。\x0d\x0a至于fetchall()则是接收全部的返回结果行 row就是在python中定义的一个变量,用来接收返回结果行的每行数据。同样后面的r也是一个变量,用来接收row中的每个字符,如果写成C的形式就更好理解了\x0d\x0afor(string row = ''row 回答于 2022-11-16欢迎分享,转载请注明来源:内存溢出
评论列表(0条)