用户注册



邮箱：

密码：

用户登录


邮箱：

密码：
记住登录一个月忘记密码？

发表随想


还能输入：200字
云代码 - java代码库

java mysql 增删改查操作

2012-09-07 作者： 芳林依依举报

[java]代码库

view sourceprint?
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 }


网友评论    (发表评论)

共1 条评论 1/1页

发表评论：

评论须知：

  • 1、评论每次加2分，每天上限为30；
  • 2、请文明用语，共同创建干净的技术交流环境；
  • 3、若被发现提交非法信息，评论将会被删除，并且给予扣分处理，严重者给予封号处理；
  • 4、请勿发布广告信息或其他无关评论，否则将会删除评论并扣分，严重者给予封号处理。


扫码下载

加载中，请稍后...

输入口令后可复制整站源码

加载中，请稍后...