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驱动动程序7JDBC体体系结构2-1Java程程序JDBC驱驱动程序数据库SQL命令令结果8JDBC体体系结构2-2应用层DriverStatementResultSetConnection各接口驱动层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.getR