编程 JDBC

TaoRL

试题3、JDBC的基本操作

本题分值：45分

考核时间：90分钟

考核方式：实操

考核内容：使用JDBC连接数据库，并进行增删改查基本操作。本题涉及的表有两张：

托运公司表（com）：包含托运公司编号，托运公司名称，电话，地址四个字段。

订单表（t_order）：包含订单号，托运公司编号，商品数量，运输方式四个字段。

托运公司表：

id	name	adress
1	顺丰速递	上海
2	申通速递	武汉
3	中远	北京

订单表：

pid	id	count	way
001	1	100	海运
002	1	50	空运
003	2	500	陆路运输
004	3	30	空运

以下sql语句对表进行了创建，添加了上面表格中的数据：

SET FOREIGN_KEY_CHECKS=0; -- ---------------------------- -- Table structure for com -- ---------------------------- DROP TABLE IF EXISTS com; CREATE TABLE com (    id int(11) NOT NULL,    name varchar(20) DEFAULT NULL,    adress varchar(20) DEFAULT NULL,   PRIMARY KEY (id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; -- ---------------------------- -- Records of com -- ---------------------------- INSERT INTO com VALUES ('1', '顺丰速递', '上海'); INSERT INTO com VALUES ('2', '申通速递', '武汉'); INSERT INTO com VALUES ('3', '中远', '北京'); -- ---------------------------- -- Table structure for t_order -- ---------------------------- DROP TABLE IF EXISTS t_order; CREATE TABLE t_order (   pid varchar(10) NOT NULL,   id int(11) NOT NULL,   count int(11) DEFAULT NULL, way varchar(20) DEFAULT NULL,   PRIMARY KEY (pid) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; -- ---------------------------- -- Records of t_order -- ---------------------------- INSERT INTO t_order VALUES ('001', '1', '100', '海运'); INSERT INTO t_order VALUES ('002', '1', '50', '空运'); INSERT INTO t_order VALUES ('003', '2', '500', '陆路运输'); INSERT INTO t_order VALUES ('004', '3', '30', '空运');

在上面sql语句的基础上请实现以下操作：

(1)创建log数据库，导入log.sql脚本；

(2)使用JDBC连接log数据库；

(3)使用JDBC向com托运公司表中插入id为4，name为圆通，adress为广州的一条记录；

(4)使用JDBC查询上海的运输公司名称；

(5)使用JDBC将com表中id为3的快递公司地址改为深圳；

(6)使用JDBC删除id为1的托运公司记录。

1. import java.sql.*;
   
2. public class JdbcLogDBOperation {
   
3.     private static final String DB_URL = "jdbc:mysql://199.7.140.3:3306/tester?characterEncoding=utf-8";
   
4.     private static final String DB_USER = "tester";
   
5.     private static final String DB_PASSWORD = "Taoch185152972#";
   
6. 
   
7.     public static Connection getConnection() throws SQLException {
   
8.         try {
   
9.             Class.forName("com.mysql.jdbc.Driver");
   
10.         } catch (ClassNotFoundException e) {
    
11.             e.printStackTrace();
    
12.         }
    
13.         return DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
    
14.     }
    
15. 
    
16.     public static void insertCom() {
    
17.         String sql = "INSERT INTO com(id, name, adress) VALUES (?,?,?)";
    
18.         try (Connection conn = getConnection();
    
19.              PreparedStatement pstmt = conn.prepareStatement(sql)) {
    
20.             // 设置参数
    
21.             pstmt.setInt(1, 4);
    
22.             pstmt.setString(2, "圆通");
    
23.             pstmt.setString(3, "广州");
    
24.             // 执行插入
    
25.             int affectedRows = pstmt.executeUpdate();
    
26.             if (affectedRows > 0) {
    
27.                 System.out.println("插入成功");
    
28.             }
    
29.         } catch (SQLException e) {
    
30.             e.printStackTrace();
    
31.         }
    
32.     }
    
33. 
    
34.     public static void queryComByAddress() {
    
35.         String sql = "SELECT name FROM com WHERE adress = ?";
    
36.         try (Connection conn = getConnection();
    
37.              PreparedStatement pstmt = conn.prepareStatement(sql)) {
    
38. 
    
39.             pstmt.setString(1, "上海");
    
40. 
    
41.             ResultSet rs = pstmt.executeQuery();
    
42. 
    
43.             System.out.println("上海的运输公司名称：");
    
44.             while (rs.next()) {
    
45.                 String name = rs.getString("name");
    
46.                 System.out.println(name);
    
47.             }
    
48.         } catch (SQLException e) {
    
49.             e.printStackTrace();
    
50.         }
    
51.     }
    
52. 
    
53.     public static void updateComAddress() {
    
54.         String sql = "UPDATE com SET adress = ? WHERE id = ?";
    
55.         try (Connection conn = getConnection();
    
56.              PreparedStatement pstmt = conn.prepareStatement(sql)) {
    
57. 
    
58.             pstmt.setString(1, "深圳");
    
59.             pstmt.setInt(2, 3);
    
60. 
    
61.             int affectedRows = pstmt.executeUpdate();
    
62.             if (affectedRows > 0) {
    
63.                 System.out.println("修改成功");
    
64.             }
    
65.         } catch (SQLException e) {
    
66.             e.printStackTrace();
    
67.         }
    
68.     }
    
69. 
    
70.     public static void deleteCom() {
    
71.         String deleteOrderSql = "DELETE FROM t_order WHERE id = ?";
    
72. 
    
73.         try (Connection conn = getConnection();
    
74.              PreparedStatement pstmt = conn.prepareStatement(deleteOrderSql)) {
    
75. 
    
76.             pstmt.setInt(1, 1);
    
77. 
    
78.             int affectedRows = pstmt.executeUpdate();
    
79.             if (affectedRows > 0) {
    
80.                 System.out.println("删除成功");
    
81.             }
    
82.         } catch (SQLException e) {
    
83.             e.printStackTrace();
    
84.         }
    
85.     }
    
86. 
    
87.     public static void main(String[] args) {
    
88.         insertCom();
    
89.         queryComByAddress();
    
90.         updateComAddress();
    
91.         deleteCom();
    
92.     }
    
93. }

复制代码