苏州无锡外贸网站建设,软件开发公司哪家好,创建全国文明城市活动,百度官方电话JDBC介绍
JDBC#xff08;Java Data Base Connectivity,java数据库连接#xff09;是一种用于执行SQL语句的Java API#xff0c;可以为多种关系数据库提供统一访问#xff0c;它由一组用Java语言编写的类和接口组成。 开发者不必为每家数据通信协议的不同而疲于奔命#…JDBC介绍
JDBCJava Data Base Connectivity,java数据库连接是一种用于执行SQL语句的Java API可以为多种关系数据库提供统一访问它由一组用Java语言编写的类和接口组成。 开发者不必为每家数据通信协议的不同而疲于奔命只需要面向JDBC提供的接口编程在运行时由对应的驱动程序操作对应的DB。
java.sql 包中包含用于以下方面的 API 通过DriverManager实用程序建立与数据库的连接 DriverManager 类建立与驱动程序的连接SQLPermission 类当代码在 Security Manager比如 applet中运行时提供权限试图通过 DriverManager 设置一个记录流Driver 接口提供用来注册和连接基于 JDBC 技术“JDBC 驱动程序”的驱动程序的 API通常仅由 DriverManager 类使用DriverPropertyInfo 类提供 JDBC 驱动程序的属性不是供一般用户使用的 向数据库发送 SQL 语句 Statement用于发送基本 SQL 语句PreparedStatement用于发送准备好的语句或基本 SQL 语句派生自 StatementCallableStatement用于调用数据库存储过程派生自 PreparedStatementConnection 接口提供创建语句以及管理连接及其属性的方法Savepoint在事务中提供保存点 获取和更新查询的结果 ResultSet 接口 SQL 类型到 Java 编程语言中的类和接口的标准映射关系 Array 接口SQL ARRAY 的映射关系Blob 接口SQL BLOB 的映射关系Clob 接口SQL CLOB 的映射关系Date 类SQL DATE 的映射关系NClob 接口SQL NCLOB 的映射关系Ref 接口SQL REF 的映射关系RowId 接口SQL ROWID 的映射关系Struct 接口SQL STRUCT 的映射关系SQLXML 接口SQL XML 的映射关系Time 类SQL TIME 的映射关系Timestamp 类SQL TIMESTAMP 的映射关系Types 类提供用于 SQL 类型的常量 自定义映射 SQL 用户定义类型 (UDT) 到 Java 编程语言中的类 SQLData 接口指定 UDT 到此类的一个实例的映射关系SQLInput 接口提供用来从流中读取 UDT 属性的方法SQLOutput 接口提供用来将 UDT 属性写回流中的方法 元数据 DatabaseMetaData 接口提供有关数据库的信息ResultSetMetaData 接口提供有关 ResultSet 对象的列的信息ParameterMetaData 接口提供有关 PreparedStatement 命令的参数的信息 异常 SQLException由大多数方法在访问数据出问题时抛出以及因为其他原因由其他一些方法抛出SQLWarning为了指示一个警告而抛出DataTruncation为了指示数据可能已经被截断而抛出BatchUpdateException为了指示并不是批量更新中的所有命令都成功执行而抛出
JDBC 的操作步骤
在进行JDBC 操作的时候可以按照以下的步骤完成
加载数据库驱动程序加载的时候需要将驱动程序配置到classpath之中连接数据库通过Connection 接口和 DriverManager 类完成操作数据库通过Statement、PreparedStatement、ResultSet 三个接口完成关闭数据库在实际开发中数据库资源非常有限操作完之后必须关闭
在JDBC 的操作中如果要想进行数据库的连接则必须按照以上的几步完成
通过Class.forName()加载数据库的驱动程序通过DriverManager 类进行数据库的连接连接的时候要输入数据库的连接地址、用户名、密码通过Connection 接口接收连接通过Statement接口操作数据。
代码示例
1、引入驱动 dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.15/version/dependency
2、加载驱动
3、建立与数据库的连接
4、创建Statement
Connection接口的createStatement方法用于创建语句对象Statement 。 Statement 对象负责对数据库执行查询。
5、执行SQL语句
6、关闭连接
public static void main(String[] args) {//连接对象Connection conn null;//SQL statement 对象Statement stmt null;try {//加载驱动Class.forName(com.mysql.cj.jdbc.Driver);//创建连接对象conn DriverManager.getConnection(jdbc:mysql://localhost:3306/mydb?useUnicodetruecharacterEncodingutf8serverTimezoneGMT,root, root);//创建Statementstmt conn.createStatement();System.out.println(连接成功获取连接对象 conn);//执行SQL语句String sql update a set x x 6 where id 6;int count stmt.executeUpdate(sql);System.out.println(返回结果count count);} catch (ClassNotFoundException | SQLException e) {e.printStackTrace();} finally {//05、关闭连接对象if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (conn ! null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}} 1、驱动类com.mysql.jdbc.Driver 已被弃用。 新的驱动程序类是com.mysql.cj.jdbc.Driver。 驱动程序通过SPI自动注册通常不需要手动加载驱动程序类。 2、从JDBC 4.0开始显式注册驱动程序是可选的。 我们只需要将相应的驱动jar放在类路径中然后JDBC驱动程序管理器就可以自动检测并加载驱动程序。 3、因为新版本的数据库驱动需要指定UTC时区将url地址后加上时区即可解决jdbc:mysql://localhost:3306/mydb?useUnicodetruecharacterEncodingutf8serverTimezoneGMT 4、从Java 7开始JDBC能够使用try-with-resources语句来自动关闭ConnectionResultSet和Statement类型的资源。 Java接口定义
Jdbc的主要接口定义在包java.sqljavax.sql下.
主要接口
DriverManager: 管理驱动程序主要用于调用驱动从数据库获取连接。Connection: 代表了一个数据库连接。Statement: 持有Sql语句执行并返回执行后的结果。ResulSet: Sql执行完毕返回的记过持有
接口定义
DriverManager
DriverManager 是用于管理JDBC驱动程序的基础服务。DriverManger 可以注册、删除、加载的驱动程序可以根据给定的url获取符合url协议的驱动Driver 并建立Conenction连接进行数据库交互。当DriverManager被使用时DriverManager类将尝试加载“ jdbc.drivers”系统属性中的驱动程序类。
JDBC 4.0驱动程序必须包含文件 META-INF/services/java.sql.Driver该文件包含了实现java.sql.Driver的JDBC驱动程序的名称。例如要加载my.sql.Driver类META-INF/services/java.sql.Driver文件中将包含以下内容my.sql.Driver。
使用DriverManager之后应用程序不再需要使用 Class.forName() 显式加载JDBC驱动程序了。已经使用 Class.forName() 显式加载JDBC驱动的程序也不会受到影响也无需刻意去修改。
当调用方法getConnection时DriverManager将尝试从初始化时加载的驱动程序和当前应用程序显式加载的驱动程序中找到合适的驱动程序。
public interface Driver {/**尝试建立给定URL的数据库连接。 如果驱动程序意识到连接到给定URL的驱动程序类型错误则应返回“ null”。 这是很常见的因为当要求JDBC驱动程序管理器连接到给定的URL时它将URL依次传递给每个已加载的驱动程序。注意如果将属性指定为url的一部分并且也在Properties对象中指定了属性则该实现将由实现定义以哪个值优先。 为了获得最大的可移植性应用程序应仅指定一次属性。*/Connection connect(String url, java.util.Properties info)throws SQLException;/**
检索驱动程序是可以打开 给定URL的连接。 通常如果驱动程序识别出 URL中指定的子协议则将返回true否则将返回false。*/boolean acceptsURL(String url) throws SQLException;/**获取有关此驱动程序可能的属性的信息。getPropertyInfo方法旨在允许通用的GUI工具发现应该提示的属性以便获得足够的信息以连接到数据库。 */DriverPropertyInfo[] getPropertyInfo(String url, java.util.Properties info)throws SQLException;/**获取驱动程序的主版本号。 最初应为1。*/int getMajorVersion();int getMinorVersion();/**报告此驱动程序是否是正版JDBC Compliant™驱动程序。 如果驱动程序通过了JDBC兼容性测试则仅在此处报告true。 否则需要返回false。JDBC合规性要求对JDBC API的完全支持和对SQL 92 Entry Level的完全支持。 期望所有主要的商业数据库都可以使用符合JDBC的驱动程序。*/boolean jdbcCompliant();//------------------------- JDBC 4.1 -----------------------------------/**返回此驱动程序使用的所有Logger的父Logger。 这应该是距离根Logger最远的Logger它仍然是该驱动程序使用的所有Logger的祖先。 配置此Logger将影响驱动程序生成的所有日志消息。 在最坏的情况下它可能是根Logger。*/public Logger getParentLogger() throws SQLFeatureNotSupportedException;
}Class.forName() 手动加载驱动
Class.forName()将对应的驱动类加载到内存中时会执行驱动类中的static 静态代码快创建一个驱动Driver的实例注册到DriverManager中供DriverManager使用。
//加载MySQL 数据库驱动
Class.forName(com.mysql.cj.jdbc.Driver);DriverManager 源码分析
DriverManager 加载驱动
DriverManager 作为 Driver 的管理器在首次被使用时会执行其定义的static静态代码块在静态代码快中有一个 loadInitialDrivers() 静态方法会首先加载配置在jdbc.drivers 系统属性内的驱动Driver。 static {loadInitialDrivers();println(JDBC DriverManager initialized);}private static void loadInitialDrivers() {String drivers;//尝试从系统属性jdbc.drivers中获取驱动类try {drivers AccessController.doPrivileged(new PrivilegedActionString() {public String run() {return System.getProperty(jdbc.drivers);}});} catch (Exception ex) {drivers null;}//使用ServiceLoader 加载驱动程序AccessController.doPrivileged(new PrivilegedActionVoid() {public Void run() {ServiceLoaderDriver loadedDrivers ServiceLoader.load(Driver.class);IteratorDriver driversIterator loadedDrivers.iterator();// 加载这些驱动程序以便可以实例化它们。try{while(driversIterator.hasNext()) {driversIterator.next();}} catch(Throwable t) {// Do nothing}return null;}});println(DriverManager.initialize: jdbc.drivers drivers);//jdbc.drivers 中的驱动处理if (drivers null || drivers.equals()) {return;}String[] driversList drivers.split(:);println(number of Drivers: driversList.length);for (String aDriver : driversList) {try {println(DriverManager.Initialize: loading aDriver);Class.forName(aDriver, true,ClassLoader.getSystemClassLoader());} catch (Exception ex) {println(DriverManager.Initialize: load failed: ex);}}}
DriverManager 注册驱动
//同步注册
public static synchronized void registerDriver(java.sql.Driver driver)throws SQLException {registerDriver(driver, null);}//CopyOnWriteArrayListprivate final static CopyOnWriteArrayListDriverInfo registeredDrivers new CopyOnWriteArrayList();public static synchronized void registerDriver(java.sql.Driver driver,DriverAction da)throws SQLException {/* Register the driver if it has not already been added to our list */if(driver ! null) {registeredDrivers.addIfAbsent(new DriverInfo(driver, da));} else {// This is for compatibility with the original DriverManagerthrow new NullPointerException();}println(registerDriver: driver);}
DriverManager 取消注册驱动 CallerSensitivepublic static synchronized void deregisterDriver(Driver driver)throws SQLException {if (driver null) {return;}SecurityManager sec System.getSecurityManager();if (sec ! null) {sec.checkPermission(DEREGISTER_DRIVER_PERMISSION);}println(DriverManager.deregisterDriver: driver);DriverInfo aDriver new DriverInfo(driver, null);//包含if(registeredDrivers.contains(aDriver)) {if (isDriverAllowed(driver, Reflection.getCallerClass())) {DriverInfo di registeredDrivers.get(registeredDrivers.indexOf(aDriver));// If a DriverAction was specified, Call it to notify the// driver that it has been deregisteredif(di.action() ! null) {di.action().deregister();}//移除registeredDrivers.remove(aDriver);} else {// If the caller does not have permission to load the driver then// throw a SecurityException.throw new SecurityException();}} else {println( couldnt find driver to unload);}}DriverManager 创建连接
通过遍历已加载的驱动程序分别尝试连接指定的数据库如果连接上则返回连接对象。 CallerSensitivepublic static Connection getConnection(String url)throws SQLException {java.util.Properties info new java.util.Properties();return (getConnection(url, info, Reflection.getCallerClass()));}CallerSensitivepublic static Connection getConnection(String url,java.util.Properties info) throws SQLException {return (getConnection(url, info, Reflection.getCallerClass()));}CallerSensitivepublic static Connection getConnection(String url,String user, String password) throws SQLException {java.util.Properties info new java.util.Properties();if (user ! null) {info.put(user, user);}if (password ! null) {info.put(password, password);}return (getConnection(url, info, Reflection.getCallerClass()));}private static Connection getConnection(String url, java.util.Properties info, Class? caller) throws SQLException {/*当callerCl为空时检查应用程序的类加载器以便可以从此处加载rt.jar外部的JDBC驱动程序类。*/ClassLoader callerCL caller ! null ? caller.getClassLoader() : null;synchronized(DriverManager.class) {// synchronize loading of the correct classloader.if (callerCL null) {callerCL Thread.currentThread().getContextClassLoader();}}if(url null) {throw new SQLException(The url cannot be null, 08001);}println(DriverManager.getConnection(\ url \));SQLException reason null;// 遍历每个驱动尝试连接指定的数据库地址for(DriverInfo aDriver : registeredDrivers) {// If the caller does not have permission to load the driver then// skip it.if(isDriverAllowed(aDriver.driver, callerCL)) {try {println( trying aDriver.driver.getClass().getName());Connection con aDriver.driver.connect(url, info);if (con ! null) {// Success!println(getConnection returning aDriver.driver.getClass().getName());return (con);}} catch (SQLException ex) {if (reason null) {reason ex;}}} else {println( skipping: aDriver.getClass().getName());}}// if we got here nobody could connect.if (reason ! null) {println(getConnection failed: reason);throw reason;}println(getConnection: no suitable driver found for url);throw new SQLException(No suitable driver found for url, 08001);}DataSource接口提供了另一种连接数据源的方法。 使用DataSource对象是连接数据源的首选方法。 Wrapper
java.sql.Wrapper 是 JDBC 的接口当相关实例实际上是代理类时该接口提供检索委托实例的功能。
许多 JDBC 驱动程序实现使用包装器模式提供超越传统 JDBC API 的扩展功能传统 JDBC API 是特定于数据源的。开发人员可能希望访问那些被包装代理为代表实际资源代理类实例的资源。
public interface Wrapper {T T unwrap(java.lang.ClassT iface) throws java.sql.SQLException;boolean isWrapperFor(java.lang.Class? iface) throws java.sql.SQLException;
}T unwrap(java.lang.Class iface)
返回一个实现给定接口的对象以允许访问非标准方法或代理未公开的标准方法。
如果接收者实现了该接口那么结果是接收者或接收者代理。如果接收者是包装器且包装对象实现了该接口那么结果是包装对象或包装对象的代理。否则返回对该包装对象或该结果的代理进行递归调用的结果。如果接收者不是包装器且未实现该接口则抛出 sqlexception。
boolean isWrapperFor(java.lang.Class? iface)
如果此方法实现了接口参数或者直接或间接地对该对象进行了包装则返回true。 否则返回false。
如果实现了接口那么返回true否则如果这是一个包装器那么返回在包装对象上递归调用isWrapperFor的结果。
如果不实现接口并且不是包装器则返回false。
与 unwrap 相比此方法应作为一种低成本操作来实现以便调用者可以使用此方法来避免可能失败的昂贵的 unwrap 调用。 如果此方法返回true则使用相同参数调用unwrap应该会成功。
java.sql.Wrapper 主要有以下子接口
DataSource该工厂用于提供到此 DataSource 对象所表示的物理数据源的连接。Connection与特定数据库的连接会话。DatabaseMetaData关于数据库的整体综合信息。ParameterMetaData可用于获取关于 PreparedStatement 对象中每个参数标记的类型和属性信息的对象。ResultSet表示数据库结果集的数据表通常通过执行查询数据库的语句生成。ResultSetMetaData可用于获取关于 ResultSet 对象中列的类型和属性信息的对象。Statement用于执行静态 SQL 语句并返回它所生成结果的对象。CallableStatement用于执行 SQL 存储过程的接口。PreparedStatement表示预编译的 SQL 语句的对象。RowSet该接口添加了对 JavaBeansTM 组件模型的 JDBC API 支持。RowSetMetaData该对象包含关于 RowSet 对象的列的信息。 Connection
Connection 是Java应用程序和特定数据库之间的会话。 用来执行SQL语句并在连接的上下文中返回结果。
public interface Connection extends Wrapper, AutoCloseable {/**创建一个Statement对象用于将SQL语句发送到数据库。 不带参数的SQL语句通常使用Statement对象执行。 如果多次执行同一条SQL语句则使用PreparedStatement对象可能会更合适。
默认情况下使用返回的Statement对象创建的结果集的类型为TYPE_FORWARD_ONLY并发级别为CONCUR_READ_ONLY。 可以通过调用getHoldability确定创建的结果集的可保存性。*/Statement createStatement() throws SQLException;/***/PreparedStatement prepareStatement(String sql)throws SQLException;CallableStatement prepareCall(String sql) throws SQLException;String nativeSQL(String sql) throws SQLException;void setAutoCommit(boolean autoCommit) throws SQLException;boolean getAutoCommit() throws SQLException;void commit() throws SQLException;void rollback() throws SQLException;void close() throws SQLException;boolean isClosed() throws SQLException;DatabaseMetaData getMetaData() throws SQLException;void setReadOnly(boolean readOnly) throws SQLException;boolean isReadOnly() throws SQLException;void setCatalog(String catalog) throws SQLException;String getCatalog() throws SQLException;/*** A constant indicating that transactions are not supported.*/int TRANSACTION_NONE 0;int TRANSACTION_READ_UNCOMMITTED 1;int TRANSACTION_READ_COMMITTED 2;int TRANSACTION_REPEATABLE_READ 4;int TRANSACTION_SERIALIZABLE 8;void setTransactionIsolation(int level) throws SQLException;int getTransactionIsolation() throws SQLException;SQLWarning getWarnings() throws SQLException;void clearWarnings() throws SQLException;//--------------------------JDBC 2.0-----------------------------Statement createStatement(int resultSetType, int resultSetConcurrency)throws SQLException;PreparedStatement prepareStatement(String sql, int resultSetType,int resultSetConcurrency)throws SQLException;CallableStatement prepareCall(String sql, int resultSetType,int resultSetConcurrency) throws SQLException;java.util.MapString,Class? getTypeMap() throws SQLException;void setTypeMap(java.util.MapString,Class? map) throws SQLException;//--------------------------JDBC 3.0-----------------------------void setHoldability(int holdability) throws SQLException;int getHoldability() throws SQLException;Savepoint setSavepoint() throws SQLException;Savepoint setSavepoint(String name) throws SQLException;void rollback(Savepoint savepoint) throws SQLException;void releaseSavepoint(Savepoint savepoint) throws SQLException;Statement createStatement(int resultSetType, int resultSetConcurrency,int resultSetHoldability) throws SQLException;PreparedStatement prepareStatement(String sql, int resultSetType,int resultSetConcurrency, int resultSetHoldability)throws SQLException;CallableStatement prepareCall(String sql, int resultSetType,int resultSetConcurrency,int resultSetHoldability) throws SQLException;PreparedStatement prepareStatement(String sql, int autoGeneratedKeys)throws SQLException;PreparedStatement prepareStatement(String sql, int columnIndexes[])throws SQLException;PreparedStatement prepareStatement(String sql, String columnNames[])throws SQLException;Clob createClob() throws SQLException;Blob createBlob() throws SQLException;NClob createNClob() throws SQLException;SQLXML createSQLXML() throws SQLException;boolean isValid(int timeout) throws SQLException;void setClientInfo(String name, String value)throws SQLClientInfoException;void setClientInfo(Properties properties)throws SQLClientInfoException;String getClientInfo(String name)throws SQLException;Properties getClientInfo()throws SQLException;Array createArrayOf(String typeName, Object[] elements) throws
SQLException;Struct createStruct(String typeName, Object[] attributes)
throws SQLException;//--------------------------JDBC 4.1 -----------------------------void setSchema(String schema) throws SQLException;String getSchema() throws SQLException;void abort(Executor executor) throws SQLException;void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException;int getNetworkTimeout() throws SQLException;
}
Statement及子接口
PreparedStatement 表示预编译的SQL语句的对象SQL语句已预编译并存储在PreparedStatement对象中。 然后可以使用该对象多次有效地执行该语句。
String sql insert into users values(?,?,?);
//可以通过setter来为每个参数赋值。pstmt.setBigDecimal(1, 153833.00)pstmt.setInt(2, 110592)public interface Statement extends Wrapper, AutoCloseable {ResultSet executeQuery(String sql) throws SQLException;int executeUpdate(String sql) throws SQLException;void close() throws SQLException;//----------------------------------------------------------------------int getMaxFieldSize() throws SQLException;void setMaxFieldSize(int max) throws SQLException;int getMaxRows() throws SQLException;void setMaxRows(int max) throws SQLException;void setEscapeProcessing(boolean enable) throws SQLException;int getQueryTimeout() throws SQLException;void setQueryTimeout(int seconds) throws SQLException;void cancel() throws SQLException;SQLWarning getWarnings() throws SQLException;void clearWarnings() throws SQLException;void setCursorName(String name) throws SQLException;boolean execute(String sql) throws SQLException;ResultSet getResultSet() throws SQLException;int getUpdateCount() throws SQLException;boolean getMoreResults() throws SQLException;//--------------------------JDBC 2.0-----------------------------void setFetchDirection(int direction) throws SQLException;int getFetchDirection() throws SQLException;void setFetchSize(int rows) throws SQLException;int getFetchSize() throws SQLException;int getResultSetConcurrency() throws SQLException;int getResultSetType() throws SQLException;/** 批次 加 sql */void addBatch( String sql ) throws SQLException;void clearBatch() throws SQLException;int[] executeBatch() throws SQLException;Connection getConnection() throws SQLException;//--------------------------JDBC 3.0-----------------------------int CLOSE_CURRENT_RESULT 1;int KEEP_CURRENT_RESULT 2;int CLOSE_ALL_RESULTS 3;int SUCCESS_NO_INFO -2;int EXECUTE_FAILED -3;int RETURN_GENERATED_KEYS 1;int NO_GENERATED_KEYS 2;boolean getMoreResults(int current) throws SQLException;ResultSet getGeneratedKeys() throws SQLException;int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException;int executeUpdate(String sql, int columnIndexes[]) throws SQLException;int executeUpdate(String sql, String columnNames[]) throws SQLException;boolean execute(String sql, int autoGeneratedKeys) throws SQLException;boolean execute(String sql, int columnIndexes[]) throws SQLException;boolean execute(String sql, String columnNames[]) throws SQLException;int getResultSetHoldability() throws SQLException;boolean isClosed() throws SQLException;void setPoolable(boolean poolable)throws SQLException;boolean isPoolable()throws SQLException;//--------------------------JDBC 4.1 -----------------------------public void closeOnCompletion() throws SQLException;public boolean isCloseOnCompletion() throws SQLException;//--------------------------JDBC 4.2 -----------------------------default long getLargeUpdateCount() throws SQLException {throw new UnsupportedOperationException(getLargeUpdateCount not implemented);}default void setLargeMaxRows(long max) throws SQLException {throw new UnsupportedOperationException(setLargeMaxRows not implemented);}default long getLargeMaxRows() throws SQLException {return 0;}default long[] executeLargeBatch() throws SQLException {throw new UnsupportedOperationException(executeLargeBatch not implemented);}default long executeLargeUpdate(String sql) throws SQLException {throw new UnsupportedOperationException(executeLargeUpdate not implemented);}default long executeLargeUpdate(String sql, int autoGeneratedKeys)throws SQLException {throw new SQLFeatureNotSupportedException(executeLargeUpdate not implemented);}default long executeLargeUpdate(String sql, int columnIndexes[]) throws SQLException {throw new SQLFeatureNotSupportedException(executeLargeUpdate not implemented);}default long executeLargeUpdate(String sql, String columnNames[])throws SQLException {throw new SQLFeatureNotSupportedException(executeLargeUpdate not implemented);}
} public interface PreparedStatement extends Statement {ResultSet executeQuery() throws SQLException;int executeUpdate() throws SQLException;/** 下面是各种数据类型的设置 */void setNull(int parameterIndex, int sqlType) throws SQLException;void setXXXX(int parameterIndex, Type x) throws SQLException;void setAsciiStream(int parameterIndex, java.io.InputStream x, int length)throws SQLException;Deprecatedvoid setUnicodeStream(int parameterIndex, java.io.InputStream x,int length) throws SQLException;void setBinaryStream(int parameterIndex, java.io.InputStream x,int length) throws SQLException;void clearParameters() throws SQLException;//----------------------------------------------------------------------// Advanced features:void setObject(int parameterIndex, Object x, int targetSqlType)throws SQLException;void setObject(int parameterIndex, Object x) throws SQLException;boolean execute() throws SQLException;//--------------------------JDBC 2.0-----------------------------/** 把当前参数 的设置 加到批次 */void addBatch() throws SQLException;void setYYY(int parameterIndex, YYY y) throws SQLException;//------------------------- JDBC 3.0 -----------------------------------void setURL(int parameterIndex, java.net.URL x) throws SQLException;ParameterMetaData getParameterMetaData() throws SQLException;//------------------------- JDBC 4.0 -----------------------------------/** 新增的数据类型*/void setRowId(int parameterIndex, RowId x) throws SQLException;void setNString(int parameterIndex, String value) throws SQLException;void setNCharacterStream(int parameterIndex, Reader value, long length) throws SQLException;//------------------------- JDBC 4.2 -----------------------------------default void setObject(int parameterIndex, Object x, SQLType targetSqlType,int scaleOrLength) throws SQLException {throw new SQLFeatureNotSupportedException(setObject not implemented);}default void setObject(int parameterIndex, Object x, SQLType targetSqlType)throws SQLException {throw new SQLFeatureNotSupportedException(setObject not implemented);}default long executeLargeUpdate() throws SQLException {throw new UnsupportedOperationException(executeLargeUpdate not implemented);}
}
使用 Statement 对象进行批处理更新
StatementPreparedStatement 和 CallableStatement 对象具有与其关联的命令列表。 该列表在创建时与 Statement 对象相关联初始是空的。 您可以使用addBatch方法将SQL命令添加到此列表并使用clearBatch方法将其清空。 完成将语句添加到列表后请调用executeBatch方法将其全部发送到数据库以作为一个单元或批处理执行。 public static void main(String[] args) throws SQLException {batchUpdate();}/*** 使用 Statement 对象进行批处理更新*/private static void batchUpdate() {//Step 1: 创建 Connection 对象try (Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/mydb?useUnicodetruecharacterEncodingutf8serverTimezoneGMT, root, root);// Step 2:使用 connection 创建 statement 对象Statement statement connection.createStatement()) {connection.setAutoCommit(false);statement.addBatch(INSERT INTO Users VALUES (1, XXX, xxxqq.com, China, 1234););statement.addBatch(INSERT INTO Users VALUES (2, YYY, yyyqq.com, China, 1235););//批处理int[] updateCounts statement.executeBatch();System.out.println(Arrays.toString(updateCounts));connection.commit();} catch (BatchUpdateException batchUpdateException) {printBatchUpdateException(batchUpdateException);} catch (SQLException e) {printSQLException(e);}}
进行参数化的批量更新
private static void parameterizedBatchUpdate() {String INSERT_USERS_SQL INSERT INTO users (id, name, email, country, password) VALUES (?, ?, ?, ?, ?);;try (Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/mydb?useUnicodetruecharacterEncodingutf8serverTimezoneGMT, root, root);PreparedStatement preparedStatement connection.prepareStatement(INSERT_USERS_SQL)) {connection.setAutoCommit(false);preparedStatement.setInt(1, 8);preparedStatement.setString(2, XXX);preparedStatement.setString(3, xxxqq.com);preparedStatement.setString(4, China);preparedStatement.setString(5, 1);preparedStatement.addBatch();preparedStatement.setInt(1, 9);preparedStatement.setString(2, YYYY);preparedStatement.setString(3, yyyyqq.com);preparedStatement.setString(4, China);preparedStatement.setString(5, 2);preparedStatement.addBatch();preparedStatement.setInt(1, 10);preparedStatement.setString(2, ZZZZ);preparedStatement.setString(3, zzzzqq.com);preparedStatement.setString(4, China);preparedStatement.setString(5, 3);preparedStatement.addBatch();preparedStatement.setInt(1, 11);preparedStatement.setString(2, DDDD);preparedStatement.setString(3, dddd.com);preparedStatement.setString(4, China);preparedStatement.setString(5, 4);preparedStatement.addBatch();int[] updateCounts preparedStatement.executeBatch();System.out.println(Arrays.toString(updateCounts));connection.commit();connection.setAutoCommit(true);} catch (BatchUpdateException batchUpdateException) {printBatchUpdateException(batchUpdateException);} catch (SQLException e) {printSQLException(e);}}
ResultSet
ResultSet 接口提供了用于检索和处理已获得结果集的方法并且ResultSet对象具有不同的功能和特性。 这些特性是type类型, concurrency并发性, cursor holdability游标可保持性。
ResultSet 对象维护一个游标该游标指向其当前数据行。 next 方法将光标移动到下一行当ResultSet对象中没有更多行时它返回false因此可以在while循环中使用它来迭代结果集。
默认的 ResultSet 对象是不可更新的并且只有仅向前移动的光标。 因此您只能从第一行到最后一行迭代一次。
可以生成可滚动或可更新的ResultSet对象。 下面的代码片段其中con是有效的Connection对象说明了如何创建一个可滚动且对其他更新不敏感并且可更新的结果集。
Statement stmt con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);ResultSet rs stmt.executeQuery(SELECT a, b FROM test);
ResultSet 接口提供了用于从当前行检索列值的getter方法getBooleangetLong等。 可以使用列的索引号或列的名称来检索值。 通常使用列索列索引编号从1开始编号。为了实现最大的可移植性应按从左到右的顺序读取每一行中的结果集列并且每一列只能读取一次。
对于getter方法JDBC驱动程序尝试将基础数据转换为getter方法中指定的Java类型并返回合适的Java值。 JDBC规范具有一个表该表显示了ResultSet getter方法可以使用的从SQL类型到Java类型的映射。
用作getter方法的列名不区分大小写。 当使用列名调用getter方法并且多个列具有相同的名称时将返回第一个匹配列的值。 对于在查询中未明确命名的列最好使用列号。 如果使用了列名则应注意确保它们的唯一这可以通过SQL AS子句来确保。
在JDBC 2.0 API中向该接口添加了一组更新程序方法。 有关getter方法的参数的注释也适用于updater方法的参数。
更新方法有两种使用方式
1、更新当前行中的列值在可滚动的ResultSet对象中光标可以前后移动移动到绝对位置或相对于当前行的位置
rs.absolute(6); // 移动光标到 rs 的第6行
rs.updateString(NAME, xxx); // 更新 NAME 列的值为 xxx
rs.updateRow(); // 更新当前数据源 rs 中的第6行操作
2、将列值插入到插入行中可更新的ResultSet对象具有与其关联的特殊行该行用作构建要插入的行的暂存区。 rs.moveToInsertRow(); // 移动游标到插入行rs.updateString(1, xxx); // 更新插入行第一列的值为 xxxrs.updateInt(2,3); // 更新第二列的值为 3rs.updateBoolean(3, true); // 更新第三列的值为 truers.insertRow();rs.moveToCurrentRow();
ResultSet 类型
ResultSet 对象的类型在两个方面确定其功能级别游标的操作方式以及ResultSet对象如何反映对基础数据源进行的并发更改。
游标的操作方式 TYPE_FORWARD_ONLY 结果集无法滚动它的光标只能从第一行之前移到最后一行之后。 结果集中包含的行取决于基础数据库如何生成的结果。 即它包含在执行查询时或在检索行时满足查询条件的行。 TYPE_SCROLL_INSENSITIVE 结果集可以滚动 它的光标可以相对于当前位置向前和向后移动并且可以移动到绝对位置。 结果集在打开时对基础数据源所做的更改不敏感。 它包含在执行查询时或在检索行时满足查询条件的行。 TYPE_SCROLL_SENSITIVE 结果可以滚动它的光标可以相对于当前位置向前和向后移动并且可以移动到绝对位置。 结果集反映在结果集保持打开状态时对基础数据源所做的更改。
ResultSet 并发性
ResultSet 对象的并发性确定了支持什么级别的更新功能。
CONCUR_READ_ONLY无法使用ResultSet接口更新ResultSet对象。CONCUR_UPDATABLE可以使用ResultSet接口更新ResultSet对象。
Cursor Holdability游标可保持性
调用方法Connection.commit可以关闭在当前事务期间创建的ResultSet对象。 但是在某些情况下这可能不是所需的行为。 ResultSet属性的可保留性使应用程序可以控制在调用提交时是否关闭ResultSet对象光标。
可以将以下ResultSet常量提供给Connection方法的createStatementprepareStatement和prepareCall
HOLD_CURSORS_OVER_COMMIT ResultSet游标未关闭它是可保持的调用方法commit时它们保持打开状态。 如果您的应用程序主要使用只读的ResultSet对象则可保持游标可能是理想的选择。CLOSE_CURSORS_AT_COMMIT 调用commit方法时将关闭ResultSet对象光标。 调用此方法时关闭游标可以提高某些应用程序的性能。
ResultSetMetaData
ResultSetMetaData 对象用于收集ResultSet的所有信息例如列的类型和属性列数列的名称列的数据类型等。简单来说它用于收集 ResultSet 的信息。
ResultSetMetaData 封装了描述 ResultSet 对象的数据内部提供了大量的方法来获取 ResultSet 的信息
ResultSet rs stmt.executeQuery(SELECT a, b, c FROM test);
ResultSetMetaData rsmd rs.getMetaData();
//获取有多少列
int numberOfColumns rsmd.getColumnCount();
boolean b rsmd.isSearchable(1);常用方法
方法描述int getColumnCount() throws SQLException返回 ResultSet 对象列的数量String getColumnName(int column) throws SQLException根据指定的索引获取列名int getColumnType(int column) throws SQLException根据指定索引检索指定列的SQL类型String getTableName(int column) throws SQLException根据列索引获取表名String getSchemaName(int column)获取指定列的表的结构int getScale(int column) throws SQLException获取指定列的小数点右边的位数。 对于不适用小数位数的数据类型返回0。int getPrecision(int column) throws SQLException获取指定列的指定列大小。
DatabaseMetaData
DatabaseMetaData 接口提供了获取数据库元数据的方法例如数据库名称数据库版本驱动程序名称表总数视图总数等。
数据库实现
数据库的实现以mysql为例。
Driver实现
当Class.forName(com.mysql.jdbc.Driver) 被执行时com.mysql.jdbc.Driver类就会被加载同时也在静态代码块中完成了向DriverManager的注册
public class Driver extends NonRegisteringDriver implements java.sql.Driver {public Driver() throws SQLException {}static {try {DriverManager.registerDriver(new Driver());} catch (SQLException var1) {throw new RuntimeException(Cant register driver!);}}
}具体实现在类NonRegisteringDriver中。 public class NonRegisteringDriver implements Driver {//System.getProperty(os.name);public static String getOSName() {return Constants.OS_NAME;}//System.getProperty(os.arch);public static String getPlatform() {return Constants.OS_ARCH;}static int getMajorVersionInternal() {return StringUtils.safeIntParse(8);}static int getMinorVersionInternal() {return StringUtils.safeIntParse(0);}public NonRegisteringDriver() throws SQLException {}public boolean acceptsURL(String url) throws SQLException {try {//helper类return ConnectionUrl.acceptsUrl(url);} catch (CJException var3) {throw SQLExceptionsMapping.translateException(var3);}}public Connection connect(String url, Properties info) throws SQLException {try {try {if (!ConnectionUrl.acceptsUrl(url)) {return null;} else {ConnectionUrl conStr ConnectionUrl.getConnectionUrlInstance(url, info);switch (conStr.getType()) {//单实例case SINGLE_CONNECTION:return ConnectionImpl.getInstance(conStr.getMainHost());case LOADBALANCE_CONNECTION:return LoadBalancedConnectionProxy.createProxyInstance((LoadbalanceConnectionUrl)conStr);case FAILOVER_CONNECTION:return FailoverConnectionProxy.createProxyInstance(conStr);//复制case REPLICATION_CONNECTION:return ReplicationConnectionProxy.createProxyInstance((ReplicationConnectionUrl)conStr);default:return null;}}} catch (UnsupportedConnectionStringException var5) {return null;} catch (CJException var6) {throw (UnableToConnectException)ExceptionFactory.createException(UnableToConnectException.class, Messages.getString(NonRegisteringDriver.17, new Object[]{var6.toString()}), var6);}} catch (CJException var7) {throw SQLExceptionsMapping.translateException(var7);}}public int getMajorVersion() {return getMajorVersionInternal();}public int getMinorVersion() {return getMinorVersionInternal();}public DriverPropertyInfo[] getPropertyInfo(String url, Properties info) throws SQLException {try {String host ;String port ;String database ;String user ;String password ;if (!StringUtils.isNullOrEmpty(url)) {//解析urlConnectionUrl connStr ConnectionUrl.getConnectionUrlInstance(url, info);if (connStr.getType() Type.SINGLE_CONNECTION) {HostInfo hostInfo connStr.getMainHost();info hostInfo.exposeAsProperties();}}if (info ! null) {host info.getProperty(PropertyKey.HOST.getKeyName());port info.getProperty(PropertyKey.PORT.getKeyName());database info.getProperty(PropertyKey.DBNAME.getKeyName());user info.getProperty(PropertyKey.USER.getKeyName());password info.getProperty(PropertyKey.PASSWORD.getKeyName());}DriverPropertyInfo hostProp new DriverPropertyInfo(PropertyKey.HOST.getKeyName(), host);hostProp.required true;hostProp.description Messages.getString(NonRegisteringDriver.3);DriverPropertyInfo portProp new DriverPropertyInfo(PropertyKey.PORT.getKeyName(), port);portProp.required false;portProp.description Messages.getString(NonRegisteringDriver.7);DriverPropertyInfo dbProp new DriverPropertyInfo(PropertyKey.DBNAME.getKeyName(), database);dbProp.required false;dbProp.description Messages.getString(NonRegisteringDriver.10);DriverPropertyInfo userProp new DriverPropertyInfo(PropertyKey.USER.getKeyName(), user);userProp.required true;userProp.description Messages.getString(NonRegisteringDriver.13);DriverPropertyInfo passwordProp new DriverPropertyInfo(PropertyKey.PASSWORD.getKeyName(), password);passwordProp.required true;passwordProp.description Messages.getString(NonRegisteringDriver.16);//5个关键属性。DriverPropertyInfo[] dpi (new JdbcPropertySetImpl()).exposeAsDriverPropertyInfo(info, 5);dpi[0] hostProp;dpi[1] portProp;dpi[2] dbProp;dpi[3] userProp;dpi[4] passwordProp;return dpi;} catch (CJException var15) {throw SQLExceptionsMapping.translateException(var15);}}public boolean jdbcCompliant() {return false;}public Logger getParentLogger() throws SQLFeatureNotSupportedException {throw new SQLFeatureNotSupportedException();}static {try {Class.forName(AbandonedConnectionCleanupThread.class.getName());} catch (ClassNotFoundException var1) {}}
}
ConnectionUrl
附录
参考
java.sql包API
PreparedStatement 性能
数据库解析SQL字符串并为其创建查询计划需要花费时间。 查询计划则是对数据库如何以最有效的方式执行查询的分析。
如果为每个查询或对数据库的更新提交新的完整SQL语句则数据库必须解析SQL并为查询创建查询计划。 通过重用现有的 PreparedStatement您可以将SQL解析和查询计划复用于后续查询。 通过减少每次执行的解析和查询计划开销这可以加快查询的执行速度。
PreparedStatement 的复用有以下两个方面
JDBC驱动程序重用 PreparedStatement。数据库重用 PreparedStatement。
首先JDBC驱动程序可以在内部缓存PreparedStatement对象从而可以重用PreparedStatement对象。 这样可以节省少许PreparedStatement创建时间。
其次缓存的解析和查询计划可能会使用相同的数据库跨Java应用程序例如集群中的应用程序服务器重用。 文章转载自： http://www.morning.bhpjc.cn.gov.cn.bhpjc.cn http://www.morning.ylsxk.cn.gov.cn.ylsxk.cn http://www.morning.yxlhz.cn.gov.cn.yxlhz.cn http://www.morning.fnxzk.cn.gov.cn.fnxzk.cn http://www.morning.dmldp.cn.gov.cn.dmldp.cn http://www.morning.czgtt.cn.gov.cn.czgtt.cn http://www.morning.jzlfq.cn.gov.cn.jzlfq.cn http://www.morning.jwefry.cn.gov.cn.jwefry.cn http://www.morning.wbyqy.cn.gov.cn.wbyqy.cn http://www.morning.sqtsl.cn.gov.cn.sqtsl.cn http://www.morning.bdypl.cn.gov.cn.bdypl.cn http://www.morning.wmmtl.cn.gov.cn.wmmtl.cn http://www.morning.rknhd.cn.gov.cn.rknhd.cn http://www.morning.fnkcg.cn.gov.cn.fnkcg.cn http://www.morning.ftmzy.cn.gov.cn.ftmzy.cn http://www.morning.jxzfg.cn.gov.cn.jxzfg.cn http://www.morning.mnkz.cn.gov.cn.mnkz.cn http://www.morning.dqkrf.cn.gov.cn.dqkrf.cn http://www.morning.ghrlx.cn.gov.cn.ghrlx.cn http://www.morning.thbkc.cn.gov.cn.thbkc.cn http://www.morning.yhglt.cn.gov.cn.yhglt.cn http://www.morning.ptmch.com.gov.cn.ptmch.com http://www.morning.gfpyy.cn.gov.cn.gfpyy.cn http://www.morning.nlffl.cn.gov.cn.nlffl.cn http://www.morning.bzwxr.cn.gov.cn.bzwxr.cn http://www.morning.nspzy.cn.gov.cn.nspzy.cn http://www.morning.nslwj.cn.gov.cn.nslwj.cn http://www.morning.ftmp.cn.gov.cn.ftmp.cn http://www.morning.yhtnr.cn.gov.cn.yhtnr.cn http://www.morning.lxdbn.cn.gov.cn.lxdbn.cn http://www.morning.gbfuy28.cn.gov.cn.gbfuy28.cn http://www.morning.fkwp.cn.gov.cn.fkwp.cn http://www.morning.ydrml.cn.gov.cn.ydrml.cn http://www.morning.srcth.cn.gov.cn.srcth.cn http://www.morning.zlrsy.cn.gov.cn.zlrsy.cn http://www.morning.bpmfl.cn.gov.cn.bpmfl.cn http://www.morning.kfstq.cn.gov.cn.kfstq.cn http://www.morning.qymqh.cn.gov.cn.qymqh.cn http://www.morning.jhyfb.cn.gov.cn.jhyfb.cn http://www.morning.wnnlr.cn.gov.cn.wnnlr.cn http://www.morning.mkrjf.cn.gov.cn.mkrjf.cn http://www.morning.cbtn.cn.gov.cn.cbtn.cn http://www.morning.rqfkh.cn.gov.cn.rqfkh.cn http://www.morning.nrzkg.cn.gov.cn.nrzkg.cn http://www.morning.ngjpt.cn.gov.cn.ngjpt.cn http://www.morning.hlhqs.cn.gov.cn.hlhqs.cn http://www.morning.gcspr.cn.gov.cn.gcspr.cn http://www.morning.mspqw.cn.gov.cn.mspqw.cn http://www.morning.zhghd.cn.gov.cn.zhghd.cn http://www.morning.kjkml.cn.gov.cn.kjkml.cn http://www.morning.kxrhj.cn.gov.cn.kxrhj.cn http://www.morning.lgwpm.cn.gov.cn.lgwpm.cn http://www.morning.cbnjt.cn.gov.cn.cbnjt.cn http://www.morning.trfrl.cn.gov.cn.trfrl.cn http://www.morning.sacxbs.cn.gov.cn.sacxbs.cn http://www.morning.dnzyx.cn.gov.cn.dnzyx.cn http://www.morning.lfcfn.cn.gov.cn.lfcfn.cn http://www.morning.weitao0415.cn.gov.cn.weitao0415.cn http://www.morning.dwmtk.cn.gov.cn.dwmtk.cn http://www.morning.gygfx.cn.gov.cn.gygfx.cn http://www.morning.zrpys.cn.gov.cn.zrpys.cn http://www.morning.hytfz.cn.gov.cn.hytfz.cn http://www.morning.xsgxp.cn.gov.cn.xsgxp.cn http://www.morning.rzjfn.cn.gov.cn.rzjfn.cn http://www.morning.mgbsp.cn.gov.cn.mgbsp.cn http://www.morning.sgpny.cn.gov.cn.sgpny.cn http://www.morning.dmwck.cn.gov.cn.dmwck.cn http://www.morning.lnnc.cn.gov.cn.lnnc.cn http://www.morning.tcylt.cn.gov.cn.tcylt.cn http://www.morning.zrwlz.cn.gov.cn.zrwlz.cn http://www.morning.rnmdp.cn.gov.cn.rnmdp.cn http://www.morning.wgrm.cn.gov.cn.wgrm.cn http://www.morning.zzgkk.cn.gov.cn.zzgkk.cn http://www.morning.zmnyj.cn.gov.cn.zmnyj.cn http://www.morning.bwrbm.cn.gov.cn.bwrbm.cn http://www.morning.qshxh.cn.gov.cn.qshxh.cn http://www.morning.fhjnh.cn.gov.cn.fhjnh.cn http://www.morning.rmxwm.cn.gov.cn.rmxwm.cn http://www.morning.sblgt.cn.gov.cn.sblgt.cn http://www.morning.zmzdx.cn.gov.cn.zmzdx.cn
