1. 
   
2. import java.sql.Connection;
   
3. import java.sql.DriverManager;
   
4. import java.sql.PreparedStatement;
   
5. import java.sql.ResultSet;
   
6. import java.sql.SQLException;
   
7. public class SqlHelper {
   
8. // 定义需要的变量
   
9. static Connection ct = null;
   
10. static PreparedStatement ps = null;
    
11. static ResultSet rs = null;
    
12. // 连接数据库的参数
    
13. private static String url = "jdbc:mysql://127.0.0.1:3306/hotel";
    
14. private static String username = "root";
    
15. private static String password = "henry";
    
16. private static String drivername = "com.mysql.jdbc.Driver";
    
17. //static Properties pp = null;
    
18. //static FileInputStream fis = null;
    
19. public SqlHelper(){
    
20. System.out.println(" 0");
    
21. // 加载驱动，只需要一次
    
22. System.out.println(ct+" 1 0");
    
23. //加载驱动
    
24. try {
    
25. System.out.println(ct+" 2 0");
    
26. Class.forName(drivername);
    
27. System.out.println(ct+" 3 0");
    
28. try {
    
29. ct=DriverManager.getConnection(url,username,password);
    
30. System.out.println(ct+" 4 0");
    
31. } catch (SQLException e) {
    
32. e.printStackTrace();
    
33. }
    
34. } catch (ClassNotFoundException e) {
    
35. }
    
36. }
    
37. // 如果有多个增删改[需要考虑事务]
    
38. // 比如：把一个学生，并同时更新该同学的所在班级的总人数
    
39. public void executeUpdate2(String sql[], String[][] parameters) {
    
40. try {
    
41. // 1.获得连接
    
42. //ct = getConnection();
    
43. // 用户出入的可能是多个sql语句
    
44. ct.setAutoCommit(false);
    
45. for (int i = 0; i < sql.length; i++) {
    
46. if (parameters[i] != null) {
    
47. ps = ct.prepareStatement(sql[i]);
    
48. for (int j = 0; j < parameters[i].length; j++) {
    
49. ps.setString(j + 1, parameters[i][j]);
    
50. }
    
51. ps.executeUpdate();
    
52. }
    
53. }
    
54. ct.commit();
    
55. } catch (Exception e) {
    
56. e.printStackTrace();
    
57. throw new RuntimeException(e.getMessage());
    
58. } finally {
    
59. close();
    
60. }
    
61. }
    
62. // 一个增删改
    
63. // sql格式：update 表名 set 字段名=？ where 字段=？
    
64. public static void executeUpdate(String sql, String[] parameters) {
    
65. // 1.创建一个ps
    
66. //ct = getConnection();
    
67. try {
    
68. System.out.println(ct+" 5 0");
    
69. System.out.println(sql);
    
70. System.out.println(parameters[0]);
    
71. <FONT color=red>ps = ct.prepareStatement(sql);//.....这里怎么回事啊 搞什么飞机啊  </FONT>
    
72. // 给？赋值
    
73. for (int i = 0; i < parameters.length; i++) {
    
74. ps.setString(i + 1, parameters[i]);
    
75. }
    
76. // 执行
    
77. ps.executeUpdate();
    
78. } catch (SQLException e) {
    
79. e.printStackTrace();
    
80. // 执行异常，抛出异常（好处：可以给调用的函数可以处理也可以不处理）
    
81. throw new RuntimeException(e.getMessage());
    
82. } finally {
    
83. // 关闭资源
    
84. close();
    
85. }
    
86. }
    
87. // 关闭资源的方法
    
88. public static void close() {
    
89. try {
    
90. if (rs != null)
    
91. rs.close();
    
92. if (ps != null)
    
93. ps.close();
    
94. if (ct != null)
    
95. ct.close();
    
96. } catch (SQLException e) {
    
97. e.printStackTrace();
    
98. }
    
99. }
    
100. }

复制代码

申请加分