java]代码 |
001 import java.sql.Connection; |
002 import java.sql.DriverManager; |
003 import java.sql.PreparedStatement; |
004 import java.sql.ResultSet; |
005 import java.sql.SQLException; |
006 |
007 public class Dao { |
008 private Connection conn = null ; |
009 PreparedStatement statement = null ; |
010 |
011 void connSQL() { |
012 String url = "jdbc:mysql://localhost:3306/test?characterEncoding=UTF-8" ; // 数据库地址,端口,数据库名称,字符集 |
013 String username = "root" ; // 数据库用户名 |
014 String password = "root" ; // 数据库密码 |
015 try { |
016 Class.forName( "com.mysql.jdbc.Driver" ); // 加载驱动,必须导入包mysql-connector-java-5.1.6-bin.jar |
017 conn = DriverManager.getConnection(url, username, password); |
018 } |
019 // 捕获加载驱动程序异常 |
020 catch (ClassNotFoundException cnfex) { |
021 System.err.println( "装载 JDBC/ODBC 驱动程序失败。" ); |
022 cnfex.printStackTrace(); |
023 } |
024 // 捕获连接数据库异常 |
025 catch (SQLException sqlex) { |
026 System.err.println( "无法连接数据库" ); |
027 sqlex.printStackTrace(); |
028 } |
029 } |
030 |
031 // 关闭数据库 |
032 void deconnSQL() { |
033 try { |
034 if (conn != null ) |
035 conn.close(); |
036 } catch (Exception e) { |
037 System.out.println( "关闭数据库异常:" ); |
038 e.printStackTrace(); |
039 } |
040 } |
041 |
042 /** |
043 * 执行查询sql语句 |
044 * |
045 * @param sql |
046 * @return |
047 */ |
048 ResultSet selectSQL(String sql) { |
049 ResultSet rs = null ; |
050 try { |
051 statement = conn.prepareStatement(sql); |
052 rs = statement.executeQuery(sql); |
053 } catch (SQLException e) { |
054 e.printStackTrace(); |
055 } |
056 return rs; |
057 } |
058 |
059 /** |
060 * 执行插入sql语句 |
061 * |
062 * @param sql |
063 * @return |
064 */ |
065 boolean insertSQL(String sql) { |
066 try { |
067 statement = conn.prepareStatement(sql); |
068 statement.executeUpdate(); |
069 return true ; |
070 } catch (SQLException e) { |
071 System.out.println( "插入数据库时出错:" ); |
072 e.printStackTrace(); |
073 } catch (Exception e) { |
074 System.out.println( "插入时出错:" ); |
075 e.printStackTrace(); |
076 } |
077 return false ; |
078 } |
079 |
080 /** |
081 * 执行删除sql语句 |
082 * |
083 * @param sql |
084 * @return |
085 */ |
086 boolean deleteSQL(String sql) { |
087 try { |
088 statement = conn.prepareStatement(sql); |
089 statement.executeUpdate(); |
090 return true ; |
091 } catch (SQLException e) { |
092 System.out.println( "删除数据库时出错:" ); |
093 e.printStackTrace(); |
094 } catch (Exception e) { |
095 System.out.println( "删除时出错:" ); |
096 e.printStackTrace(); |
097 } |
098 return false ; |
099 } |
100 |
101 /** |
102 * 执行更新sql语句 |
103 * |
104 * @param sql |
105 * @return |
106 */ |
107 boolean updateSQL(String sql) { |
108 try { |
109 statement = conn.prepareStatement(sql); |
110 statement.executeUpdate(); |
111 return true ; |
112 } catch (SQLException e) { |
113 System.out.println( "更新数据库时出错:" ); |
114 e.printStackTrace(); |
115 } catch (Exception e) { |
116 System.out.println( "更新时出错:" ); |
117 e.printStackTrace(); |
118 } |
119 return false ; |
120 } |
121 |
122 /** |
123 * 打印结果集 |
124 * |
125 * 具体列根据自己的数据库表结构更改 |
126 * |
127 * @param rs |
128 */ |
129 void print(ResultSet rs) { |
130 System.out.println( "-----------------" ); |
131 System.out.println( "查询结果:" ); |
132 System.out.println( "-----------------" ); |
133 |
134 try { |
135 while (rs.next()) { |
136 System.out.println(rs.getInt( 0 ) + "/t/t" + rs.getString( 1 ) |
137 + "/t/t" + rs.getString( 2 )); |
138 } |
139 } catch (SQLException e) { |
140 System.out.println( "显示时数据库出错。" ); |
141 e.printStackTrace(); |
142 } catch (Exception e) { |
143 System.out.println( "显示出错。" ); |
144 e.printStackTrace(); |
145 } |
146 } |
147 |
148 public static void main(String args[]) { |
149 |
150 Dao dao = new Dao(); |
151 dao.connSQL(); // 连接数据库 |
152 String s = "select * from users" ; |
153 |
154 String insert = "insert into users(userID,userName,userPWD) values('10000','10000','10000')" ; |
155 String update = "update users set userPWD =20000 where userID= '10000'" ; |
156 String delete = "delete from users where userID= '10000'" ; |
157 |
158 if (dao.insertSQL(insert) == true ) { |
159 System.out.println( "插入成功" ); |
160 ResultSet resultSet = dao.selectSQL(s); |
161 dao.print(resultSet); |
162 } |
163 if (dao.updateSQL(update) == true ) { |
164 System.out.println( "更新成功" ); |
165 ResultSet resultSet = dao.selectSQL(s); |
166 dao.print(resultSet); |
167 } |
168 if (dao.insertSQL(delete) == true ) { |
169 System.out.println( "删除成功" ); |
170 ResultSet resultSet = dao.selectSQL(s); |
171 dao.print(resultSet); |
172 } |
173 |
174 dao.deconnSQL(); // 关闭数据库连接 |
175 } |
176 } |
高级设计师
by: 神马 发表于:2012-09-07 10:41:32 顶(0) | 踩(0) 回复
请不要直接复制本站代码,你可以直接点击代码右上方的收藏,进入你的收藏夹即可查看该代码。
回复评论