java 数据库 笔试题及答案

java数据库笔试题及答案Java数据库笔试题及答案一、选择题（30分）1.JDBC中用于执行SQL语句的接口是：A.ConnectionB.StatementC.DriverManagerD.ResultSet答案：B解析：Statement接口用于执行SQL语句并返回结果。Connection接口用于与数据库建立连接，DriverManager用于管理JDBC驱动，ResultSet用于存储查询结果。易错警示：混淆Connection和Statement的功能，需明确Connection负责连接管理，而Statement负责执行SQL。2.以下哪个不是JDBC驱动类型？A.JDBC-ODBC桥接驱动B.本地API驱动C.网络协议驱动D.纯Java驱动E.混合驱动答案：E解析：JDBC驱动类型分为四种：JDBC-ODBC桥接驱动、本地API驱动、网络协议驱动和纯Java驱动。混合驱动并非标准JDBC驱动类型。易错警示：混淆驱动类型分类，需明确JDBC规范定义的四种驱动类型及其特点。3.在PreparedStatement中，使用哪个方法设置参数？A.setParameter()B.setValue()C.set()D.setXXX()答案：D解析：PreparedStatement接口提供了setXXX()方法族用于设置参数，如setInt(),setString()等。setParameter()和setValue()不是JDBCAPI中的方法。易错警示：混淆PreparedStatement参数设置方法，需记住使用setXXX()系列方法，其中XXX表示参数的数据类型。4.以下哪个SQL子句用于对结果集进行排序？A.WHEREB.GROUPBYC.HAVINGD.ORDERBY答案：D解析：ORDERBY子句用于对查询结果进行排序。WHERE用于过滤条件，GROUPBY用于分组，HAVING用于过滤分组结果。易错警示：混淆SQL子句功能，需明确ORDERBY是唯一用于排序的子句，且通常位于SQL语句末尾。5.在Java中，以下哪个方法用于关闭数据库连接？A.closeConnection()B.terminate()C.close()D.shutdown()答案：C解析：Connection接口提供了close()方法用于关闭数据库连接。其他方法都不是JDBCAPI中的标准方法。易错警示：混淆Connection对象关闭方法，需明确使用close()方法而非其他自定义名称的方法。6.以下哪个不是Java连接数据库的步骤？A.加载驱动B.建立连接C.执行SQLD.编译Java代码答案：D解析：Java连接数据库的步骤包括：加载驱动、建立连接、创建Statement、执行SQL、处理结果、关闭资源。编译Java代码是开发过程中的步骤，而非连接数据库的步骤。易错警示：混淆Java开发流程与数据库连接步骤，需明确区分代码编译和数据库操作是不同的过程。7.在事务管理中，以下哪个方法用于提交事务？A.commit()B.save()C.apply()D.finish()答案：A解析：Connection接口提供了commit()方法用于提交事务。save()、apply()和finish()不是JDBCAPI中的事务管理方法。易错警示：混淆事务提交方法，需明确Connection对象的commit()方法是提交事务的标准方法。8.以下哪个ResultSet类型支持滚动和更新？A.TYPE_FORWARD_ONLYB.TYPE_SCROLL_INSENSITIVEC.TYPE_SCROLL_SENSITIVED.CONCUR_READ_ONLY答案：C解析：TYPE_SCROLL_SENSITIVE类型的ResultSet支持滚动和更新。TYPE_FORWARD_ONLY只支持向前滚动，TYPE_SCROLL_INSENSITIVE支持滚动但不反映数据变化，CONCUR_READ_ONLY是并发模式而非类型。易错警示：混淆ResultSet类型和并发模式，需明确TYPE_SCROLL_SENSITIVE是唯一同时支持滚动和更新的类型。9.在JDBC中，以下哪个异常类表示SQL语法错误？A.SQLExceptionB.SQLSyntaxErrorExceptionC.SQLDataExceptionD.SQLFeatureNotSupportedException答案：B解析：SQLSyntaxErrorException是SQLException的子类，专门表示SQL语法错误。SQLException是通用SQL异常，SQLDataException表示数据访问错误，SQLFeatureNotSupportedException表示不支持的功能。易错警示：混淆SQL异常类型，需明确SQLSyntaxErrorException专门用于语法错误场景。10.以下哪个方法用于获取ResultSet中的行数？A.getRowCount()B.size()C.rowCount()D.没有直接方法答案：D解析：ResultSet接口没有直接获取行数的方法。需要通过遍历ResultSet或使用COUNT()查询来获取行数。易错警示：误以为ResultSet有直接获取行数的方法，需明确ResultSet是游标导向的结果集，不提供直接获取行数的方法。11.在连接池技术中，以下哪个接口是Java标准API中定义的？A.DataSourceB.ConnectionPoolC.PoolDataSourceD.BasicDataSource答案：A解析：DataSource是Java标准API中定义的接口，用于获取数据库连接。ConnectionPool、PoolDataSource和BasicDataSource是第三方库中的类，不是Java标准API。易错警示：混淆连接池相关接口和实现类，需明确DataSource是Java标准API中的接口，其他可能是第三方实现。12.以下哪个SQL函数用于计算平均值？A.SUM()B.COUNT()C.AVG()D.MAX()答案：C解析：AVG()函数用于计算平均值。SUM()用于求和，COUNT()用于计数，MAX()用于求最大值。易错警示：混淆聚合函数功能，需明确AVG()是计算平均值的专用函数。13.在JDBC中，以下哪个方法用于设置事务隔离级别？A.setTransactionIsolation()B.setIsolationLevel()C.setTransactionLevel()D.setIsolation()答案：A解析：Connection接口提供了setTransactionIsolation()方法用于设置事务隔离级别。其他方法名称都不是JDBCAPI中的标准方法。易错警示：混淆事务隔离级别设置方法，需明确使用setTransactionIsolation()方法。14.以下哪个不是数据库连接的URL组成部分？A.协议B.子协议C.数据标识D.端口号答案：D解析：数据库连接URL的格式通常为：协议:子协议://数据标识。端口号是可选部分，不是必须的组成部分。易错警示：混淆URL组成部分，需明确端口号是可选部分，而非必需组成部分。15.在Java中，以下哪个注解用于配置JPA实体？A.@EntityB.@TableC.@ColumnD.以上都是答案：D解析：@Entity、@Table和@Column都是JPA中用于配置实体的注解。@Entity标记类为实体，@Table指定表名，@Column指定列属性。易错警示：混淆JPA注解功能，需明确这些注解都是JPA实体配置的一部分。二、填空题（20分）1.JDBC中，用于加载驱动类的静态方法是______。答案：Class.forName()解析：Class.forName()是用于加载JDBC驱动类的静态方法。例如：Class.forName("com.mysql.jdbc.Driver")。定义：Class.forName()是Java反射API中的方法，用于动态加载指定类名的类。易错警示：混淆驱动加载方法，需明确使用Class.forName()而非直接实例化驱动类。2.在PreparedStatement中，使用问号(?)表示______。答案：参数占位符解析：在PreparedStatement中，问号(?)作为参数占位符，用于表示需要后续设置的参数。例如：SELECTFROMusersWHEREid=?。公式：参数位置从1开始计数，即第一个参数位置为1，第二个为2，以此类推。易错警示：混淆参数位置计数方式，需明确参数位置从1开始而非0。3.在事务管理中，______方法用于回滚事务。答案：rollback()解析：Connection接口提供的rollback()方法用于回滚当前事务，撤销所有未提交的更改。定义：事务回滚是指将数据库状态恢复到事务开始前的状态，撤销事务中的所有操作。易错警示：混淆事务回滚与提交方法，需明确rollback()用于回滚，commit()用于提交。4.在ResultSet中，______方法用于将游标移动到下一行。答案：next()解析：ResultSet接口的next()方法用于将游标移动到下一行，并返回是否还有更多数据。例如：while(rs.next()){//处理当前行}。易错警示：混淆游标移动方法，需明确next()是向前移动游标的方法，没有previous()方法（除非使用特定类型的结果集）。5.在SQL中，______关键字用于从多个表中获取数据。答案：JOIN解析：JOIN关键字用于基于相关列从两个或多个表中获取数据。例如：SELECTFROMordersJOINcustomersONorders.cust_id=customers.id。易错警示：混淆JOIN与其他表连接方式，需明确JOIN是标准SQL中用于表连接的关键字。6.在JDBC中，______接口表示数据库元数据。答案：DatabaseMetaData解析：DatabaseMetaData接口提供了关于数据库的整体信息，如数据库版本、支持的功能、表信息等。例如：DatabaseMetaDatameta=conn.getMetaData();。易错警示：混淆元数据类型，需明确DatabaseMetaData用于数据库级元数据，ResultSetMetaData用于结果集级元数据。7.在连接池中，______方法用于从池中获取连接。答案：getConnection()解析：DataSource接口的getConnection()方法用于从连接池中获取数据库连接。例如：Connectionconn=dataSource.getConnection();。易错警示：混淆连接获取方式，需明确使用DataSource的getConnection()方法而非直接创建连接。8.在SQL中，______子句用于对结果进行分组。答案：GROUPBY解析：GROUPBY子句用于将结果集按一个或多个列进行分组，常与聚合函数一起使用。例如：SELECTdepartment,COUNT()FROMemployeesGROUPBYdepartment;。易错警示：混淆分组与过滤，需明确GROUPBY用于分组，HAVING用于过滤分组结果。9.在JDBC中，______类用于表示SQL查询结果。答案：ResultSet解析：ResultSet类用于表示SQL查询的结果集，提供对数据的访问方法。例如：ResultSetrs=stmt.executeQuery("SELECTFROMusers");。易错警示：混淆结果集类型，需明确ResultSet是标准的结果集表示类。10.在JPA中，______注解用于标记主键字段。答案：@Id解析：@Id注解用于标记实体类中的主键字段。例如：@IdprivateLongid;。定义：主键是表中唯一标识每一行记录的字段或字段组合。易错警示：混淆主键注解，需明确@Id是标记主键的专用注解，与其他注解如@GeneratedValue配合使用。三、判断题（10分）1.Statement接口用于执行静态SQL语句，而PreparedStatement用于执行预编译的SQL语句。答案：正确解析：Statement用于执行静态SQL语句，每次执行都需要编译；PreparedStatement用于执行预编译的SQL语句，参数化查询，效率更高且能防止SQL注入。定义：预编译是指SQL语句在执行前被编译并存储，后续执行只需设置参数值。易错警示：混淆Statement和PreparedStatement的使用场景，需明确PreparedStatement更适合参数化查询和重复执行的SQL。2.在JDBC中，ResultSet的默认类型是可滚动的。答案：错误解析：ResultSet的默认类型是TYPE_FORWARD_ONLY，只能向前滚动，不支持滚动和更新。要获得可滚动的ResultSet，需要显式指定类型为TYPE_SCROLL_INSENSITIVE或TYPE_SCROLL_SENSITIVE。公式：创建可滚动ResultSet的语法为：stmt=conn.createStatement(TYPE_SCROLL_SENSITIVE,CONCUR_UPDATABLE);。易错警示：误以为ResultSet默认是可滚动的，需明确默认类型是TYPE_FORWARD_ONLY。3.在事务中，一旦调用commit()方法，所有更改将永久保存到数据库。答案：正确解析：commit()方法用于提交事务，将事务中的所有更改永久保存到数据库。提交后，事务结束，新的事务自动开始。定义：事务提交是指将事务中的所有操作永久保存到数据库的过程。易错警示：混淆提交与回滚操作，需明确commit()用于保存更改，rollback()用于撤销更改。4.在SQL中，HAVING子句必须与GROUPBY子句一起使用。答案：正确解析：HAVING子句用于过滤分组后的结果，因此必须与GROUPBY子句一起使用。如果未使用GROUPBY，则应使用WHERE子句进行过滤。公式：SELECTcolumn1,aggregate_function(column2)FROMtableGROUPBYcolumn1HAVINGcondition;。易错警示：混淆HAVING与WHERE的使用场景，需明确WHERE用于过滤行，HAVING用于过滤分组。5.在JDBC中，Connection对象的close()方法会自动回滚未提交的事务。答案：正确解析：当调用Connection对象的close()方法时，如果存在未提交的事务，大多数JDBC驱动会自动回滚该事务。这是为了确保连接关闭时数据库处于一致状态。定义：自动回滚是指当连接关闭时，系统自动撤销未提交的事务操作。易错警示：误以为连接关闭会提交事务，需明确连接关闭通常会导致未提交事务回滚。四、简答题（20分）1.简述JDBC的工作原理及其主要组成部分。答案：JDBC(JavaDatabaseConnectivity)是JavaAPI的一部分，用于连接Java应用程序和各种数据库。其工作原理是通过JDBC驱动程序作为桥梁，使Java代码能够与数据库进行交互。JDBC的主要组成部分包括：(1)JDBCAPI：Java标准库中的一组接口和类，如Connection、Statement、ResultSet等，供开发者使用。(2)JDBC驱动程序：实现JDBC接口的具体类，负责与特定数据库进行通信。(3)数据库：存储数据的目标系统。JDBC的工作流程通常包括：加载驱动、建立连接、创建Statement对象、执行SQL、处理结果、关闭资源。解析：JDBC的核心思想是提供统一的API访问不同数据库，通过驱动程序实现数据库特定的操作。定义：JDBC是Java语言中用来规范客户端程序如何访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。易错警示：混淆JDBC与JPA等ORM框架，需明确JDBC是底层API，而ORM框架建立在JDBC之上提供更高层次的抽象。2.解释事务的ACID特性及其在Java数据库编程中的实现。答案：事务的ACID特性是指：(1)原子性(Atomicity)：事务是一个不可分割的工作单元，事务中的所有操作要么全部成功，要么全部失败回滚。(2)一致性(Consistency)：事务必须使数据库从一个一致的状态转变到另一个一致的状态，保持数据的完整性约束。(3)隔离性(Isolation)：并发执行的事务之间相互隔离，一个事务的执行不应影响其他事务。(4)持久性(Durability)：一旦事务提交，它对数据库的更改就是永久性的，即使系统发生故障也不会丢失。在Java数据库编程中，事务通过Connection对象的方法实现：-设置事务隔离级别：setTransactionIsolation(intlevel)-开启事务：默认情况下，JDBC在自动提交模式下，可通过setAutoCommit(false)手动开启事务-提交事务：commit()-回滚事务：rollback()解析：事务管理是数据库操作中的重要概念，确保数据操作的可靠性和一致性。公式：事务的基本操作模式为：开始事务→执行操作→提交或回滚。易错警示：混淆事务隔离级别与锁机制，需明确隔离级别定义了事务之间的可见性规则，而锁是实现隔离性的具体机制。3.比较Statement和PreparedStatement的区别，并说明PreparedStatement的优势。答案：Statement和PreparedStatement的主要区别：(1)语句类型：Statement用于执行静态SQL语句，而PreparedStatement用于执行预编译的参数化SQL语句。(2)性能：PreparedStatement在首次执行时会进行预编译，后续执行只需设置参数值，性能更高；Statement每次执行都需要编译SQL语句。(3)安全性：PreparedStatement能有效防止SQL注入攻击，因为它将SQL语句和数据分开处理；Statement直接拼接SQL字符串，容易受到SQL注入攻击。(4)灵活性：Statement可以执行任意SQL语句；PreparedStatement主要用于参数化查询，不适合动态SQL构建。PreparedStatement的优势：(1)性能优势：对于重复执行的SQL语句，PreparedStatement只需编译一次，后续执行效率更高。(2)安全性优势：通过参数化查询有效防止SQL注入攻击。(3)可读性优势：SQL语句结构清晰，参数值单独设置，代码更易读和维护。(4)类型安全优势：提供类型检查，减少运行时错误。解析：PreparedStatement是Java数据库编程中推荐的Statement使用方式，特别是在参数化查询场景下。定义：参数化查询是将SQL语句中的变量值用参数占位符(?)表示，然后在执行时设置参数值的查询方式。易错警示：误认为PreparedStatement总是比Statement性能更好，需注意对于一次性执行的简单SQL，两者性能差异不大。4.简述数据库连接池的原理及其在Java中的实现方式。答案：数据库连接池的原理：数据库连接池是一种重用数据库连接的技术，它维护一组数据库连接对象，应用程序需要连接时从池中获取，使用完毕后归还给池中，而不是每次都创建和销毁连接。连接池的工作流程：(1)初始化时创建一定数量的连接（最小连接数）放入池中。(2)当应用程序请求连接时，从池中获取一个可用连接。(3)使用完连接后，将连接归还给池中而非关闭。(4)当连接数达到最大值时，新请求将等待直到有可用连接。(5)定期检查池中的连接，移除无效或超时的连接。在Java中，连接池的实现方式：(1)使用JDBC标准DataSource接口：通过实现DataSource接口创建连接池，如ApacheCommonsDBCP的BasicDataSource。(2)使用第三方连接池库：如HikariCP、C3P0、Druid等高性能连接池。(3)应用服务器提供的连接池：如Tomcat的JNDI数据源、WebLogic的数据源等。使用连接池的基本步骤：(1)配置连接池参数（URL、用户名、密码、最大连接数等）。(2)通过JNDI或直接实例化获取DataSource对象。(3)调用DataSource的getConnection()方法获取连接。(4)使用完毕后调用Connection的close()方法归还连接。解析：连接池是提高数据库操作性能的关键技术，特别是在高并发应用中。计算过程：连接池的效率提升可以通过公式：(创建连接时间×连接数)/(获取连接时间)来评估，通常这个比值远大于1。易错警示：混淆连接获取与关闭方式，需明确使用连接池时，调用close()实际是归还连接而非关闭物理连接。五、编程题（15分）1.编写一个Java方法，使用JDBC连接MySQL数据库，并查询指定表中的所有数据，结果以List<Map<String,Object>>形式返回。答案：```javaimportjava.sql.;importjava.util.ArrayList;importjava.util.HashMap;importjava.util.List;importjava.util.Map;publicclassDatabaseQuery{/查询指定表中的所有数据@paramurl数据库URL@paramusername用户名@parampassword密码@paramtableName表名@return包含查询结果的列表，每个元素代表一行数据，以Map形式存储@throwsSQLException如果数据库访问出错/publicstaticList<Map<String,Object>>queryAllData(Stringurl,Stringusername,Stringpassword,StringtableName)throwsSQLException{List<Map<String,Object>>resultList=newArrayList<>();Connectionconn=null;Statementstmt=null;ResultSetrs=null;try{//1.加载驱动Class.forName("com.mysql.jdbc.Driver");//2.建立连接conn=DriverManager.getConnection(url,username,password);//3.创建Statementstmt=conn.createStatement();//4.执行查询Stringsql="SELECTFROM"+tableName;rs=stmt.executeQuery(sql);//5.处理结果集ResultSetMetaDatametaData=rs.getMetaData();intcolumnCount=metaData.getColumnCount();while(rs.next()){Map<String,Object>rowMap=newHashMap<>();for(inti=1;i<=columnCount;i++){StringcolumnName=metaData.getColumnName(i);ObjectcolumnValue=rs.getObject(i);rowMap.put(columnName,columnValue);}resultList.add(rowMap);}}catch(ClassNotFoundExceptione){thrownewSQLException("MySQL驱动未找到",e);}finally{//6.关闭资源if(rs!=null)rs.close();if(stmt!=null)stmt.close();if(conn!=null)conn.close();}returnresultList;}}```解析：此方法实现了使用JDBC查询数据库表并返回结果的功能。关键点包括：加载驱动类、建立连接、创建Statement、执行查询、处理结果集和关闭资源。定义：ResultSetMetaData是用于获取结果集元数据的接口，如表的列名、数据类型等信息。易错警示：忘记关闭资源可能导致连接泄漏，需在finally块中确保所有资源被正确关闭；同时注意SQL注入风险，在实际应用中应使用PreparedStatement。2.编写一个Java方法，使用JDBC实现批量插入数据到数据库表中，并处理事务。答案：```javaimportjava.sql.;importjava.util.List;publicclassBatchInsert{/批量插入数据到指定表@paramurl数据库URL@paramusername用户名@parampassword密码@paramtableName表名@paramcolumns列名列表@paramdataList要插入的数据列表，每个元素是一个Object数组，代表一行数据@return成功插入的记录数@throwsSQLException如果数据库访问出错/publicstaticintbatchInsert(Stringurl,Stringusername,Stringpassword,StringtableName,List<String>columns,List<Object[]>dataList)throwsSQLException{Connectionconn=null;PreparedStatementpstmt=null;//构建SQL语句StringBuildersqlBuilder=newStringBuilder("INSERTINTO");sqlBuilder.append(tableName).append("(");for(inti=0;i<columns.size();i++){sqlBuilder.append(columns.get(i));if(i<columns.size()-1){sqlBuilder.append(",");}}sqlBuilder.append(")VALUES(");for(inti=0;i<columns.size();i++){sqlBuilder.append("?");if(i<columns.size()-1){sqlBuilder.append(",");}}sqlBuilder.append(")");Stringsql=sqlBuilder.toString();int[]result=null;try{//1.加载驱动Class.forName("com.mysql.jdbc.Driver");//2.建立连接conn=DriverManager.getConnection(url,username,password);//3.关闭自动提交，开启事务conn.setAutoCommit(false);//4.创建PreparedStatementpstmt=conn.prepareStatement(sql);//5.设置参数并添加到批处理for(Object[]rowData:dataList){for(inti=0;i<rowData.length;i++){pstmt.setObject(i+1,rowData[i]);}pstmt.addBatch();}//6.执行批处理result=pstmt.executeBatch();//7.提交事务mit();}catch(ClassNotFoundExceptione){thrownewSQLException("MySQL驱动未找到",e);}catch(SQLExceptione){//发生异常时回滚事务if(conn!=null){try{conn.rollback();}catch(SQLExceptionex){thrownewSQLException("事务回滚失败",ex);}}throwe;}finally{//8.恢复自动提交if(conn!=null){try{conn.setAutoCommit(true);}catch(SQLExceptione){thrownewSQLException("恢复自动提交失败",e);}}//9.关闭资源if(pstmt!=null)pstmt.close();if(conn!=null)conn.close();}//计算成功插入的记录数intsuccessCount=0;if(result!=null){for(inti:result){successCount+=i;}}returnsuccessCount;}}```解析：此方法实现了使用JDBC批量插入数据并处理事务的功能。关键点包括：构建参数化SQL语句、关闭自动提交以开启事务、使用PreparedStatement进行批处理、处理异常时回滚事务、恢复自动提交和关闭资源。公式：批处理的效率提升可以通过公式：(单次插入时间×记录数)/(批处理时间)来评估，通常这个比值远大于1。易错警示：批处理时需注意内存使用，大批量数据应分批处理；同时务必在异常情况下回滚事务，确保数据一致性。六、材料综合题（5分）1.某电商平台需要实现一个商品库存管理系统，要求在高并发情况下保证库存数据的准确性和一致性。请设计一个基于Java和数据库的解决方案，包括数据库表设计、关键业务逻辑实现和并发控制策略。答案：数据库表设计：```sqlCREATETABLEproducts(idBIGINTPRIMARYKEYAUTO_INCREMENT,nameVARCHAR(100)NOTNULL,priceDECIMAL(10,2)NOTNULL,stockINTNOTNULLDEFAULT0,versionINTNOTNULLDEFAULT0,created_atTIMESTAMPDEFAULTCURRENT_TIMESTAMP,updated_atTIMESTAMPDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP);CREATETABLEorders(idBIGINTPRIMARYKEYAUTO_INCREMENT,order_noVARCHAR(50)NOTNULLUNIQUE,total_amountDECIMAL(10,2)NOTNULL,statusTINYINTNOTNULLDEFAULT0,--0:待支付,1:已支付,2:已发货,3:已完成,4:已取消created_atTIMESTAMPDEFAULTCURRENT_TIMESTAMP,updated_atTIMESTAMPDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP);CREATETABLEorder_items(idBIGINTPRIMARYKEYAUTO_INCREMENT,order_idBIGINTNOTNULL,product_idBIGINTNOTNULL,quantityINTNOTNULL,priceDECIMAL(10,2)NOTNULL,created_atTIMESTAMPDEFAULTCURRENT_TIMESTAMP,FOREIGNKEY(order_id)REFERENCESorders(id),FOREIGNKEY(product_id)REFERENCESproducts(id));```关键业务逻辑实现：```javaimportjava.sql.;importjava.util.ArrayList;importjava.util.List;publicclassInventoryService{privateConnectiongetConnection()throwsSQLException{//实际应用中应使用连接池returnDriverManager.getConnection("jdbc:mysql://localhost:3306/ecommerce","username","password");}/扣减库存@paramproductId商品ID@paramquantity扣减数量@return是否成功扣减/publicbooleandeductStock(LongproductId,intquantity){Connectionconn=null;try{conn=getConnection();conn.setAutoCommit(false);//开启事务//1.查询当前库存和版本号StringselectSql="SELECTstock,versionFROMproductsWHEREid=?";PreparedStatementselectStmt=conn.prepareStatement(selectSql);selectStmt.setLong(1,productId);ResultSetrs=selectStmt.executeQuery();if(!rs.next()){conn.rollback();returnfalse;//商品不存在}intcurrentStock=rs.getInt("stock");intversion=rs.getInt("version");if(currentStock<quantity){conn.rollback();returnfalse;//库存不足}//2.使用乐观锁更新库存StringupdateSql="UPDATEproductsSETstock=stock-?,version=version+1WHEREid=?ANDversion=?";PreparedStatementupdateStmt=conn.prepareStatement(updateSql);updateStmt.setInt(1,quantity);updateStmt.setLong(2,productId);updateStmt.setInt(3,version);intaffectedRows=updateStmt.executeUpdate();if(affectedRows==0){conn.rollback();returnfalse;//更新失败，可能被其他事务修改}mit();returntrue;}catch(SQLExceptione){if(conn!=null){try{conn.rollback();}catch(SQLExceptionex){//记录日志}}returnfalse;}finally{if(conn!=null){try{conn.setAutoCommit(true);conn.close();}catch(SQLExceptione){//记录日志}}}}/创建订单并扣减库存@paramitems订单项列表@return订单ID，失败返回null/publicLongcreateOrderWithDeduct(List<OrderItem>items){Connectionconn=null;try{conn=getConnection();conn.setAutoCommit(false);//1.扣减库存for(OrderItemitem:items){if(!deductStock(conn,item.getProductId(),item.getQuantity())){conn.rollback();returnnull;}}//2.创建订单StringorderSql="INSERTINTOorders(order_no,total_amount)VALUES(?,?)";PreparedStatementorderStmt=conn.prepareStatement(orderSql,Statement.RETURN_GENERATED_KEYS);orderStmt.setString(1,generateOrderNo());orderStmt.setBigDecimal(2,calculateTotalAmount(items));orderStmt.executeUpdate();ResultSetrs=orderStmt.getGeneratedKeys();if(!rs.next()){conn.rollback();returnnull;}LongorderId=rs.getLong(1);//3.创建订单项StringitemSql="INSERTINTOorder_items(order_id,product_id,quantity,price)VALUES(?,?,?,?)";