JDBC讲课流程.docx
《JDBC讲课流程.docx》由会员分享，可在线阅读，更多相关《JDBC讲课流程.docx（16页珍藏版）》请在冰点文库上搜索。
JDBC讲课流程
JDBC讲课流程
第一课
JDBC概述和基本数据库操作
JDBC（javadatabaseconnectivity）用于在java程序中实现数据库操作的数据库编程接口，支持基本的SQL语句，为应用程序和数据库之间提供了桥梁
java程序和数据库之间的关系如下图：
JDBC的版本：
介绍java中和操作数据库相关的API，解释这些API都是未实现的，真正实现操作的是数据库厂家提供的类库
。
开始数据库编程：
（别忘先导入包）
第一步加载数据库驱动程序
这是利用反射注册一个数据库驱动
或者用驱动管理器也可以注册数据库驱动
第二步创建数据库连接对象
Stringuser="scott";
Stringpwd="tiger";
Connectionconn=（url,user,pwd）;
其中dhc表示的是数据库名或域名而并非是服务名
DriverManager类存有已注册的Driver类的清单。
当调用方法getConnection时，它将检查清单中的每个驱动程序，直到找到可与URL中指定的数据库进行连接的驱动程序为止。
如果改成用OCI形式连接，url字符串改为类似以下语句：
Stringurl="jdbc:
oracle:
oci8:
scott/tiger@dhc";
或者
Stringurl="jdbc:
oracle:
oci:
scott/tiger@dhc";
第三步创建SQL语句载体对象
第四步执行SQL语句返回结果集对象
第五步遍历结果集返回数据
while
}
在这一步讲解结果集指针的概念，默认状态下游标只能向下移动
需要注意getXXX方法的数据类型要和表中字段的数据类型兼容。
讲解getXXX（）括号中的参数既可以是列索引，也可以是列名，如果使用列名并且结果集中有多个列的名字是相同的，那么返回第一列的的列值，一般用列索引效率会高一些
介绍方法，当前最后一次getXXX（）返回的列值是否为null，需要注意的是如果get方法以数字的形式获取列值且返回的列值为null，得到的结果会自动的转换为0或
别忘记在下面介绍java的数据类型和SQL的数据类型之间的映射关系
第六步关闭对象释放资源
采取逆向关闭对象的顺序
在关闭stmt对象或利用stmt对象重新执行其他SQL语句时时会自动关闭rs对象。
解讲数据类型之间的映射关系
SQL类型
JAVA类型
CHAR
String
REAL
Float
DATALINK
REF
Ref
STRUCT
Struct
DISTINCT
Mappingofunderlyingtype
ARRAY
Array
BLOB
Blob
CLOB
Clob
TIMESTAMP
TIME
DATE
LONGVARBINARY
byte[]
VARBINARY
byte[]
BINARY
byte[]
DOUBLE
double
FLOAT
double
VARCHAR
String
LONGVARCHAR
String
以上操作的完整代码：
publicclassJDBC1{
publicstaticvoidmain（String[]args）throwsSQLException{
xecuteQuery（9）;
while
""""
""
}
}catch（SQLExceptione）{
}finally{
try{
if（rs!
=null）
if（stmt!
=null）
if（conn!
=null）
}catch（Exceptione）{
}
}
}
}
综合练习：
查询job_history表中所有数据，将数据写入到文本文件中，一条记录一行，列值之间用|隔开
import
import
publicclassTest7{
publicstaticvoidmain（String[]args）{
Connectionconn=null;
Statementstmt=null;
ResultSetrs=null;
FileWriterfw=null;
BufferedWriterbw=null;
try{
（new
Stringurl="jdbc:
oracle:
thin:
@localhost:
1521:
dhc";
Stringuser="scott";
Stringpwd="tiger";
conn=（url,user,pwd）;
stmt=（）;
"select*fromjob_history"）;
fw=newFileWriter（）;
bw=newBufferedWriter（fw）;
while
"|""|"
"|""|"
}
}catch（SQLExceptione）{
}catch（IOExceptione）{
}finally{
try{
if（bw!
=null）
if（rs!
=null）
if（stmt!
=null）
if（conn!
=null）
}catch（Exceptione）{
}
}
}
}
第二课
数据增删改和可滚动结果集
讲述Statement对象执行SQL语句的三种方法：
executeQuery（）执行查询单个结果集的语句，该语句返回单个ResultSet对象
executeUpdate（）执行给定SQL语句，该语句可能为INSERT、UPDATE或DELETE语句，或者不返回任何内容的SQL语句（如SQLDDL语句），该语句返回影响的行数，如果是DDL语句则返回0
execute（）执行给定的SQL语句，这个SQL语句可能实现并不知道是查询还是增删改，返回值是布尔值，如果是查询语句返回结果则为true，可以用getResultSet得到ResultSet结果
创建一个学生表做数据增删改试验：
createtableStudent
（
sidnumber,
snamevarchar2（50）,
addDatedate
）;
演示增加学生数据
publicclassTest8{
publicstaticvoidmain（String[]args）{
Connectionconn=null;
Statementstmt=null;
try{
Stringurl="jdbc:
oracle:
thin:
@localhost:
1521:
dhc";
Stringuser="scott";
Stringpwd="tiger";
inti=stmt
.executeUpdate（"insertintoStudentvalues（101,'tom',to_date（'2008-3-1','yyyy-mm-dd'））"）;
}catch（SQLExceptione）{
}finally{
try{
if（stmt!
=null）
if（conn!
=null）
}catch（Exceptione）{
}
}
}
}
演示修改学生数据：
……
inti=stmt
.executeUpdate（"updateStudentsetsname='jack',addDate=to_date（'2007-3-1','yyyy-mm-dd'）wheresid=101"）;
"操作了"+i+"行"）;
……
学生自己动手改成删除101学生数据：
……
inti=stmt
.executeUpdate（"deletefromStudentwheresid=101"）;
"操作了"+i+"行"）;
……
学生试验执行DDL语句删除表:
……
inti=stmt
.executeUpdate（"droptableStudent"）;
……
学生练习：
提供一个原始文本文件，将文本文件中的数据导入到数据库中的表中
101,tom,2008-3-1
102,jack,2008-3-2
103,rose,2008-3-3
104,smith,2008-3-4
105,john,2008-3-5
106,zhang,2008-3-6
107,li,2008-3-7
import
import
publicclassTest10{
publicstaticvoidmain（String[]args）throwsException{
Connectionconn=null;
Statementstmt=null;
ResultSetrs=null;
（new
Stringurl="jdbc:
oracle:
thin:
@localhost:
1521:
dhc";
Stringuser="scott";
Stringpwd="tiger";
conn=（url,user,pwd）;
TYPE_SCROLL_INSENSITIVE,
;
FileReaderfr=newFileReader（）;
BufferedReaderbr=newBufferedReader（fr）;
while（s!
=null）{
","）;
"insertintoStudentvalues（"+rows[0]+",'"
+rows[1]+"',to_date（'"+rows[2]+"','yyyy-mm-dd'））"）;
}
}
}
讲解可滚动的结果集游标指针
Connection对象创建Statement对象有两种形式：
●一种是用createStatement（）无参方法，这种方法创建的Statement对象执行的查询的结果集指针只能向下移动
●另一种方法是用createStatement（intresultSetType,intresultSetConcurrency）有参方法，这种方法创建的Statement对象执行的查询结果集的指针是可以任意移动的
后一种方法有两个参数：
分别是结果集游标类型和结果集是否可更新
结果集游标类型有三个设置值：
1.指针只能向下移动（默认）
2.指针可任意滚动，但结果集中被更新的行不可视
3.指针可任意滚动，结果集中被更新的行可视
结果集是否可更新有两个设置值：
1.只读（默认）
2.可更新记录
关于指针移动的方法：
默认打开结果集的时候指针位于第一行记录的上面
next（）下一行
previous（）上一行
first（）第一行
last（）最后一行
absolute（n）定位到第n条
relative（n）相对于当前指针位置定位到第n条，n为正数下移，n为负数上移
beforeFirst（）第一条的前面
afterLast（）最后一条的后面
getRow（）获得当前行的行号
学生练习：
查询出工资排名在第6位到第10位的员工编号，姓名和工资
……
TYPE_SCROLL_INSENSITIVE,
;
"select*fromemployeesorderbysalarydesc"）;
if
for（inti=6;i<=10;i++）{
+":
\t""/"
"/"
if
break;
}
}
……
学生练习2（选做）：
每次执行程序都随机查询出1个员工的编号和姓名作为中奖名单，以前已经中过奖的员工不在抽奖的范围内
创建一个临时表存放中过奖的员工编号
createtableaward（employee_idnumber）;
代码片断
TYPE_SCROLL_INSENSITIVE,
;
xecuteQuery（"select*fromemployeeswhereemployee_idnotin（selectemployee_idfromaward）"）;
xecuteQuery（"select*fromemployeeswhereemployee_idnotin（selectemployee_idfromaward）"）;
Conn5月10日repareStatement（"selectemployee_id,last_name,salary,hire_date,department_idfromemployeeswheredepartment_idbetweenand"）;
Calendarcalendar=newGregorianCalendar（）;
}
讲述已存储过程（CallableStatement）
CallableStatement对象为所有的DBMS提供了一种以标准形式调用已储存过程的方法。
已储
存过程储存在数据库中。
对已储存过程的调用是CallableStatement对象所含的内容。
这种调用是
用一种换码语法来写的，有两种形式：
一种形式带结果参，另一种形式不带结果参数。
结果参数是一种输出（OUT）参数，是已储存过程的返回值。
两种形式都可带有数量可变的输入（IN参数）、
输出（OUT参数）或输入和输出（INOUT参数）的参数。
问号将用作参数的占位符。
使用已存储过程的好处是存储过程在数据库中就已经编译了，执行速度相对会快一些。
调用无返回值存储过程的语法：
Cal“{call过程名[（,,...）]}”）;
调用有返回值存储过程（函数）的语法
Cal“{=call过程名[（,,...）]}”）;
演示调用无返回值的存储过程：
在oralce中创建存储过程add_salary，传入员工编号和给员工涨的工资金额进行工资更新
createorreplaceprocedureadd_salary（p_empidnumber,p_moneynumber）
is
begin
updateemployeessetsalary=salary+p_money
whereemployee_id=p_empid;
end;
java代码
publicclassTest20{
publicstaticvoidmain（String[]args）{
Connectionconn=null;
CallableStatementcstmt=null;
try{
Stringurl="jdbc:
oracle:
thin:
@localhost:
1521:
dhc";
Stringuser="scott";
Stringpwd="tiger";
}catch（ClassNotFoundExceptione）{
}catch（SQLExceptione）{
}finally{
try{
if（cstmt!
=null）
if（conn!
=null）
}catch（Exceptione）{
}
}
}
}
修改存储过程add_salary为存储函数，更新员工工资后返回员工的姓名和员工的新工资
createorreplacefunctionadd_salary（p_empidnumber,p_moneynumber,p_salaryoutnumber）
returnvarchar2
is
v_namevarchar2（50）;
begin
updateemployeessetsalary=salary+p_money
whereemployee_id=p_empid;
selectlast_name,salaryintov_name,p_salaryfromemployees
whereemployee_id=p_empid;
returnv_name;
end;
java代码
……
urrentTimeMillis（）））;
setAutoCommit设置是否自动提交，默认是true
为了试验数据库事务，首先先创建两个员工表和部门表的备份，然后给部门表增加触发器，在中午11点到13点之间不允许增删改部门表中的数据。
数据库脚本：
createtableempcopy
as
select*fromemployees;
createtabledeptcopy
as
select*fromdepartments;
createorreplacetriggerdept_dml_tri
before
insertorupdateordeleteondeptcopy
begin
ifto_char（sysdate,'hh24'）between11and12then
raise_application_error（-20001,'在此时间不能对数据进行操作！
'）;
endif;
end;
编写java程序传入部门编号删除指定的部门信息和员工信息
先演示没有做事务处理的情况，如果部门删除不了，当员工一样会被删除
import
publicclassTest24{
publicstaticvoidmain（String[]args）{
intdeptid=0;
repareStatement（"deletefromempcopywheredepartment_id="）;
repareStatement（"deletefromdeptcopywheredepartment_id="）;
repareStatement（"updatestudentsetsname=,addDate=wheresid="）;
new
int
returncount;
}
etDate（3））;
}
returnlist;
}
arse（addDate））;
学生信息已插入！
”）;
}catch（ParseExceptione）{
日期格式不正确！
”）;
}
}elseif（cmd==3）{arse（addDate））;
intI
if（I>0）{
学生信息已更新！
”）;
}else{
学生信息不存在！
”）;
}
}catch（ParseExceptione）{
日期格式不正确！
”）;
}
}elseif（cmd==4）{repareStatement（"updatestudentsetsname=,addDate=wheresid="）;
new
int
returncount;
}
etDate（3））;
}
returnlist;
}
2008-7-7ookup（"java:
comp/env/oracle/test"）;
//获得连接对象
//查询数据和正常写都是一样的
Stringsql="select*fromemployees";
while
","
}
//这不是关闭，这是把连接对象还给连接池
%>
升级会员 