JDBC基础结构知识

第十三章JDBC基础知识回顾JTable的用途如何使用JTableJTree的用途如何使用JTree2本章目标了解JDBC的概念及必要性了解JDBC驱动程序类型理解JDBC程序的结构运用JDBC进行数据库编程

3数据库访问技术简介

客户机/服务器应用程序数据库编程ODBCJDBC两个常用的API数据库执行SQL语句检索查询结果4数据库ODBC客户机/服务器GUI应用程序ODBC（开放式数据库连接）（Microsoft提供）插入删除修改应用程序编程接口查询5JDBCJDBC（Java数据库连接）（sun公司提供）Java应用程序编程接口Java应用程序数据库插入修改删除查询6JDBC驱动程序的类型JDBC驱动程序的类型JDBC-ODBC桥驱动程序及ODBC驱动程序本地API部分Java驱动程序JDBC-Net纯Java驱动程序本地协议纯Java驱动程序7

JDBC体系结构2-1Java程序JDBC驱动程序数据库SQL命令结果8JDBC体系结构2-2应用层Driver

StatementResultSet

Connection

各接口驱动层9java.sql包3-1接口名说明

Connection此接口表示与数据的连接PreparedStatement此接口用于执行预编译的SQL语句

ResultSet此接口表示了查询出来的数据库数据结果集Statement此接口用于执行SQL语句并将数据检索到ResultSet中

10java.sql包包3-2类名说明

DriverManager此类用于加载和卸载各种驱动程序并建立与数据库的连接Date此类包含将SQL日期格式转换成Java日期格式的各种方法Time此类用于表示时间TimeStamp此类通过添加纳秒字段为时间提供更高的精确度

11java.sql包包3-3SQLException/***fooBar*/publicvoidfoobar()throwsSQLException{……thrownewSQLException(“刚引引发了一个SQLException”);}……try{fooBar();}catch(SQLExceptionex){System.out.println(“已已捕获一个SQLException异常常!”);System.out.println(“消消息:“+ex.getMessage());System.out.println(“错错误代码:““+ex.getErrorCode());}…调用fooBar12JDBC程程序访问数据库的的步骤2-1开始导入java.sql包加载并注册驱驱动程序创建一个Connection对对象创建一个Statement对象象执行语句关闭ResultSet对对象关闭Statement对象象关闭连接结束使用ResultSet对象象13Friends表的结结构JDBC程程序访问数据库的的步骤2-2它演示访问数数据库的各个个步骤在执行示例1中的程程序之前，SQLServer中中应该存在在一个名为friends的的表演示：示例例1列名称数据类型名称

Varchar(50)地址Varchar(50)电话Numeric入职日期Datetime工资Numeric/**©©2005AptechLimited*版权所所有*/importjava.sql.SQLException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.Statement;importjava.sql.ResultSet;/**这这个类演示示访问数据据库需遵循循的各个步步骤.*@version1.0,2005年年8月月26日*@authorBen*/classJdbctest{/**构构造方法*/protectedJdbctest(){}/**这是是main方法法.*/publicstaticvoidmain(String[]args){try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}catch(ClassNotFoundExceptionce){System.out.println(ce);}try{Stringurl="jdbc:odbc:test";Connectioncon=DriverManager.getConnection(url);Statements=con.createStatement();ResultSetrs=s.executeQuery("select*fromfriends");while(rs.next()){System.out.print(rs.getString(1)+"\t");System.out.print(rs.getString(2)+"\t");System.out.print(rs.getInt(3)+"\t");System.out.print(rs.getDate(4)+"\t");System.out.println("");}rs.close();s.close();con.close();}catch(SQLExceptionce){System.out.println(ce);}}}14JDBC查查询2-1SQL查询询字符串executeQuery()方方法作为参数传递递ResultSet返回查询数据据SELECTname,email,phoneFROMcolleagues;使用SQL语句，查查询可编写为为：Stringstr="SELECTemp_id,lname,fnameFROMcolleagues";Statementstmt=con.createStatement();ResultSetrset=stmt.executeQuery(str);使用JDBC编写此此查询，则代代码为：Statement接口口15JDBC查查询2-2它演示SQL中sum()方法的用用法演示：示例2/***Jdbctest2*/importjava.sql.SQLException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.Statement;importjava.sql.ResultSet;/**这个个类演示SQL中sum()方法的用用法*@version1.0,2005年年8月月26日日*@authorBen*/classJdbctest2{/**构造造方法*/protectedJdbctest2(){}/**这是是main方法*/publicstaticvoidmain(String[]args){try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}catch(ClassNotFoundExceptionce){System.out.println(ce);}try{Stringurl="jdbc:odbc:test";Connectioncon=DriverManager.getConnection(url);Statements=con.createStatement();ResultSetrs=s.executeQuery("selecthiredate,sum(salary)fromfriendsgroupbyhiredate");while(rs.next()){System.out.print(rs.getDate(1)+"\t");System.out.print(rs.getInt(2)+"\t");System.out.println("");}rs.close;s.close();con.close();}catch(SQLExceptionce){System.out.println(ce);}}}16演示：示例3它演示SQL中INSERT语句的用用法/***Jdbctest3*/importjava.sql.SQLException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.Statement;importjava.sql.ResultSet;/**这个个类演示INSERT语句的用用法.*@version1.0,2005年年8月月26日日*@authorBen*/classJdbctest3{/**构造造方法*/protectedJdbctest3(){}JDBC插插入数据实现现/**这是是main方法*/publicstaticvoidmain(String[]args){try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}catch(ClassNotFoundExceptionce){System.out.println(ce);}try{Stringurl="jdbc:odbc:test";Stringstr="INSERTINTO““+friends(name,address,salary)“+"VALUES(‘‘朱八‘,’’深圳‘,25690)";Connectioncon=DriverManager.getConnection(url);Statements=con.createStatement();introwcount=s.executeUpdate(str);Stringstr1="selectname,sum(salary)““+fromfriends"+"groupbyname";ResultSetrs=s.executeQuery(str1);while(rs.next()){System.out.print(rs.getString(1)+"\t");System.out.print(rs.getInt(2)+"\t");System.out.println("");}rs.close();s.close();con.close();}catch(SQLExceptionce){System.out.println(ce);}}}17JDBC删删除和修改实实现它演示SQL中各种种命令的用法法演示：示例4/***Jdbc2*/importjava.sql.SQLException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.Statement;/**这这这个类演示SQL中命令的用法法.*@version1.0,2005年8月26日*@authorBen*/classJdbc2{/**构造造方法.*/protectedJdbc2(){}publicstaticvoidmain(String[]args){Connectioncon;Statementstmt;Stringurl;Stringsql;try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}catch(ClassNotFoundExceptionce){System.out.println(ce);}try{url="jdbc:odbc:test";con=DriverManager.getConnection(url);sql="Deletefromfriendswherertrim(name)like\'张三\';";System.out.println("");stmt=con.createStatement();stmt.executeUpdate(sql);System.out.println("张三的记录录已删除“);stmt.close();con.close();con=DriverManager.getConnection(url);sql="Updatefriendssetaddress=\'青岛\'where“+"rtrim(name)like\'李四\';";System.out.println("");stmt=con.createStatement();stmt.executeUpdate(sql);stmt.close();con.close();System.out.println("李李四的记录已已更新");}catch(SQLExceptionce){System.out.println(ce);}}}18PreparedStatement接口3-1PreparedStatement接口（预编译的SQL语语句）PreparedStatement用于提高运行行时效率执行PreparedStatement对象比执行Statement对对象快Statement接接口19PreparedStatement接口3-2它演示了PreparedStatement的用法演示：示例5/**©*CourseAppl*/importjava.sql.SQLException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.Statement;importjava.sql.ResultSet;importjava.sql.PreparedStatement;/**这个个类演示SQL中PreparedStatement的用用法*/classCourseAppl{privateConnectioncon;privateStringurl;privateStringserverName;privateStringportNumber;privateStringdatabaseName;privateStringuserName;privateStringpassword;privateStringsql;CourseAppl(){url="jdbc:microsoft:sqlserver://";serverName=“localhost";portNumber="1433";databaseName=““test";userName=““sa";password=““sa";}privateStringgetConnectionUrl(){returnurl+serverName+":"+portNumber+";databaseName="+databaseName+";";}privatejava.sql.ConnectiongetConnection(){try{Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");con=DriverManager.getConnection(getConnectionUrl(),userName,password);if(con!=null){System.out.println("连连接成功!");}}catch(Exceptione){e.printStackTrace();System.out.println("getConnection()内内的错误跟跟踪:"+e.getMessage());}returncon;}publicvoiddisplay(){try{con=getConnection();PreparedStatementpstmt=con.prepareStatement("UPDATEfriendsSETsalary=?WHEREnamelike?");pstmt.setInt(1,10000);pstmt.setString(2,"李李四");pstmt.executeUpdate();System.out.println(“记记录已更新!");Statements=con.createStatement();Stringsql="SELECT*FROMfriends";ResultSetrs=s.executeQuery(sql);while(rs.next()){System.out.println("");System.out.print(rs.getInt(1)+"");System.out.println(rs.getInt(5));}}catch(SQLExceptionce){System.out.println(ce);}}publicstaticvoidmain(String[]args){CourseApplretObj=newCourseAppl();retObj.display();}}20PreparedStatement

接口口3-3它演示在基于于条件的SQL查询询中如何使用用PreparedStatement，其其中条件在IN参数数中给出演示：示例6importjava.sql.SQLException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.ResultSet;importjava.sql.PreparedStatement;/**这个个类演示在基基于条件的SQL查查询中使用PreparedStatement*/classRetrieveRecords{privateConnectioncon;privateStringurl;privateStringserverName,portNumber,databaseName,userName;privateStringsql;RetrieveRecords(){url="jdbc:microsoft:sqlserver://";serverName=“localhost";portNumber="1433";databaseName=““test";userName=““sa";password=““sa";}privateStringgetConnectionUrl(){returnurl+serverName+":"+portNumber+";databaseName="+databaseName+";";}privatejava.sql.ConnectiongetConnection(){try{Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");con=DriverManager.getConnection(getConnectionUrl(),userName,password);if(con!=null){System.out.println("连连接成功!");}}catch(Exceptione){e.printStackTrace();System.out.println(“getConnection()内内的错误跟跟踪："+e.getMessage());}returncon;}publicvoiddisplay(){try{con=getConnection();sql="select*fromFriendswhereSalary>?";PreparedStatementpstmt=con.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);pstmt.setInt(1,5000);ResultSetrs=pstmt.executeQuery();while(rs.next()){System.out.print(rs.getString(1)+"\t");System.out.print(rs.getString(2)+"\t");System.out.print(rs.getInt(3)+"\t");System.out.print(rs.getDate(4)+"\t");System.out.print(rs.getInt(5)+"\t");System.out.println("");}rs.close();pstmt.close();con.close();}catch(SQLExceptionce){System.out.println(ce);}}/**这这是是main方方法法*/publicstaticvoidmain(String[]args){RetrieveRecordsretRec=newRetrieveRecords();retRec.display();}}21使用用结结果果集集3-1ResultSet对对象象完完全全依依赖赖于于Statement对对象象和和Connection对象象每次次执执行行SQL语语句句时时，，都都会会用用新新的的结结果果重重写写结结果果集集当相相关关的的Statement关关闭闭时时，，ResultSet对对象象会会自自动动关关闭闭Next()get<Type>()此方方法法将将光光标标从从当前前位位置置下下移移一一行行从ResultSet对象象返返回回数数据据22使用用结结果果集集3-2它演演示示对对当当前前行行的的处处理理使用用next()方方法法时时，，记记录录是是按按顺顺序序处处理理的的必须须按按照照数数据据返返回回的的顺顺序序处处理理每每行行中中的的数数据据…ResultSetrset=stmt.getResultSet();while(rset.next()){Stringdept_name=rset.getString(1);}…23使用用结结果果集集3-3演示示对对当当前前列列的的处处理理使用用get<Type>()方法法可可以以直直接接访访问问列