java mysql 增删改查操作

[java]代码库

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 }