java jdbc 连接mysql数据库 实现增删改查

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java jdbc 连接mysql数据库 实现增删改查，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8896字，纯文字阅读大概需要13分钟。

内容图文

第四步，创建实体类（如上图，大家观察包的分配，我们将采用MVC思想设计本实例，有关于mvc的设计思想，请大家自行学习，这里不多说）代码如下：

 1 package com.czgo.model;
 2 
 3 import java.io.Serializable;
 4 
 5 /**
 6  * 实体类：女神类
 7  * 
 8  * @author AlanLee
 9  * 
10  */
11 public class Goddess implements Serializable
12 {
13     private static final long serialVersionUID = 1L;
14 
15     /**
16      * 唯一主键
17      */
18     private Integer id;
19     /**
20      * 姓名
21      */
22     private String name;
23     /**
24      * 手机号码
25      */
26     private String mobie;
27     /**
28      * 电子邮件
29      */
30     private String email;
31     /**
32      * 家庭住址
33      */
34     private String address;
35 
36     public Integer getId()
37     {
38         return id;
39     }
40 
41     public void setId(Integer id)
42     {
43         this.id = id;
44     }
45 
46     public String getName()
47     {
48         return name;
49     }
50 
51     public void setName(String name)
52     {
53         this.name = name;
54     }
55 
56     public String getMobie()
57     {
58         return mobie;
59     }
60 
61     public void setMobie(String mobie)
62     {
63         this.mobie = mobie;
64     }
65 
66     public String getEmail()
67     {
68         return email;
69     }
70 
71     public void setEmail(String email)
72     {
73         this.email = email;
74     }
75 
76     public String getAddress()
77     {
78         return address;
79     }
80 
81     public void setAddress(String address)
82     {
83         this.address = address;
84     }
85 }

第五步，dao层的实现（这里由于是小例子没有写dao接口，实际工作中大型项目应该是要写dao接口的，便于程序的维护和扩展），代码如下：

  1 package com.czgo.dao;
  2 
  3 import java.sql.Connection;
  4 import java.sql.PreparedStatement;
  5 import java.sql.ResultSet;
  6 import java.sql.SQLException;
  7 import java.util.ArrayList;
  8 import java.util.List;
  9 
 10 import com.czgo.db.DBUtil;
 11 import com.czgo.model.Goddess;
 12 
 13 /**
 14  * 数据层处理类
 15  * 
 16  * @author AlanLee
 17  * 
 18  */
 19 public class GoddessDao
 20 {
 21     /**
 22      * 查询全部女神
 23      * 
 24      * @return
 25      * @throws SQLException
 26      */
 27     public List<Goddess> query() throws SQLException
 28     {
 29         List<Goddess> goddessList = new ArrayList<Goddess>();
 30 
 31         // 获得数据库连接
 32         Connection conn = DBUtil.getConnection();
 33 
 34         StringBuilder sb = new StringBuilder();
 35         sb.append("select id,name,mobie,email,address from goddess");
 36 
 37         // 通过数据库的连接操作数据库，实现增删改查
 38         PreparedStatement ptmt = conn.prepareStatement(sb.toString());
 39 
 40         ResultSet rs = ptmt.executeQuery();
 41 
 42         Goddess goddess = null;
 43 
 44         while (rs.next())
 45         {
 46             goddess = new Goddess();
 47             goddess.setId(rs.getInt("id"));
 48             goddess.setName(rs.getString("name"));
 49             goddess.setMobie(rs.getString("mobie"));
 50             goddess.setEmail(rs.getString("email"));
 51             goddess.setAddress(rs.getString("address"));
 52 
 53             goddessList.add(goddess);
 54         }
 55         return goddessList;
 56     }
 57 
 58     /**
 59      * 查询单个女神
 60      * 
 61      * @return
 62      * @throws SQLException
 63      */
 64     public Goddess queryById(Integer id) throws SQLException
 65     {
 66         Goddess g = null;
 67 
 68         Connection conn = DBUtil.getConnection();
 69 
 70         String sql = "" + " select * from imooc_goddess " + " where id=? ";
 71 
 72         PreparedStatement ptmt = conn.prepareStatement(sql);
 73 
 74         ptmt.setInt(1, id);
 75 
 76         ResultSet rs = ptmt.executeQuery();
 77 
 78         while (rs.next())
 79         {
 80             g = new Goddess();
 81             g.setId(rs.getInt("id"));
 82             g.setName(rs.getString("name"));
 83             g.setMobie(rs.getString("mobie"));
 84             g.setEmail(rs.getString("email"));
 85             g.setAddress(rs.getString("address"));
 86         }
 87 
 88         return g;
 89     }
 90 
 91     /**
 92      * 添加女神
 93      * 
 94      * @throws SQLException
 95      */
 96     public void addGoddess(Goddess goddess) throws SQLException
 97     {
 98         // 获得数据库连接
 99         Connection conn = DBUtil.getConnection();
100 
101         String sql = "insert into goddess(name,mobie,email,address) values(?,?,?,?)";
102 
103         PreparedStatement ptmt = conn.prepareStatement(sql);
104 
105         ptmt.setString(1, goddess.getName());
106         ptmt.setString(2, goddess.getMobie());
107         ptmt.setString(3, goddess.getEmail());
108         ptmt.setString(4, goddess.getAddress());
109 
110         ptmt.execute();
111     }
112 
113     /**
114      * 修改女神资料
115      * 
116      * @throws SQLException
117      */
118     public void updateGoddess(Goddess goddess) throws SQLException
119     {
120         Connection conn = DBUtil.getConnection();
121 
122         String sql = "update goddess set name=?,mobie=?,email=?,address=? where id=?";
123 
124         PreparedStatement ptmt = conn.prepareStatement(sql);
125 
126         ptmt.setString(1, goddess.getName());
127         ptmt.setString(2, goddess.getMobie());
128         ptmt.setString(3, goddess.getEmail());
129         ptmt.setString(4, goddess.getAddress());
130 
131         ptmt.execute();
132     }
133 
134     /**
135      * 删除女神
136      * 
137      * @throws SQLException
138      */
139     public void deleteGoddess(Integer id) throws SQLException
140     {
141         Connection conn = DBUtil.getConnection();
142 
143         String sql = "delete from goddess where id=?";
144 
145         PreparedStatement ptmt = conn.prepareStatement(sql);
146 
147         ptmt.setInt(1, id);
148 
149         ptmt.execute();
150     }
151 }

第六步，控制层的实现（控制层在此处用来模仿控制层和界面，直接在这里构建数据，如果是界面的数据则通过请求传递接收参数即可，控制层的代码大家可以根据实际情况去更改完善，这里只是给大家抛砖引玉，做个简单的测试，时间比较紧，希望大家理解），代码如下：

 1 package com.czgo.action;
 2 
 3 import java.sql.SQLException;
 4 import java.util.List;
 5 
 6 import com.czgo.dao.GoddessDao;
 7 import com.czgo.model.Goddess;
 8 
 9 /**
10  * 控制层，直接在这里构建数据，界面的数据则通过请求传递接收即可，亦是同理
11  * 
12  * @author AlanLee
13  * 
14  */
15 public class GoddessAction
16 {
17     /**
18      * 新增女神
19      * 
20      * @param goddess
21      * @throws Exception
22      */
23     public void add(Goddess goddess) throws Exception
24     {
25         GoddessDao dao = new GoddessDao();
26         goddess.setName("苍井空");
27         goddess.setMobie("52220000");
28         goddess.setEmail("52220000@qq.com");
29         goddess.setAddress("北京红灯区");
30         dao.addGoddess(goddess);
31     }
32 
33     /**
34      * 查询单个女神
35      * 
36      * @param id
37      * @return
38      * @throws SQLException
39      */
40     public Goddess get(Integer id) throws SQLException
41     {
42         GoddessDao dao = new GoddessDao();
43         return dao.queryById(id);
44     }
45 
46     /**
47      * 修改女神
48      * 
49      * @param goddess
50      * @throws Exception
51      */
52     public void edit(Goddess goddess) throws Exception
53     {
54         GoddessDao dao = new GoddessDao();
55         dao.updateGoddess(goddess);
56     }
57 
58     /**
59      * 删除女神
60      * 
61      * @param id
62      * @throws SQLException
63      */
64     public void del(Integer id) throws SQLException
65     {
66         GoddessDao dao = new GoddessDao();
67         dao.deleteGoddess(id);
68     }
69 
70     /**
71      * 查询全部女神
72      * 
73      * @return
74      * @throws Exception
75      */
76     public List<Goddess> query() throws Exception
77     {
78         GoddessDao dao = new GoddessDao();
79         return dao.query();
80     }
81 
82     /**
83      * 测试是否成功
84      * 
85      * @param args
86      * @throws SQLException
87      */
88     public static void main(String[] args) throws SQLException
89     {
90         GoddessDao goddessDao = new GoddessDao();
91 
92         List<Goddess> goddessList = goddessDao.query();
93 
94         for (Goddess goddess : goddessList)
95         {
96             System.out.println(goddess.getName() + "," + goddess.getMobie() + "," + goddess.getEmail());
97         }
98     }
99 }

最后，让我们看一下main方法的运行结果是否成功：

这样，一个简单的java jdbc 连接mysql数据库 实现增删改查便完成了，大家可以在查询的基础上试着去做一个高级查询，也就是多条件查询来巩固jdbc的使用。

现在21：00，还没有吃晚饭，时间比较紧，所以没有给大家一一测试增删改查的功能，闲着没事做蛋疼的可以都去测试一下，如果发现问题，希望能够指正小Alan，小Alan有空的时候便去修正博文中的一些错误。

最后的最后，祝大家今晚都能够做一个美美的梦，小Alan吃晚饭去了，下次再会！

java jdbc 连接mysql数据库 实现增删改查

标签：

本文系统来源：http://www.cnblogs.com/AlanLee/p/5656640.html

内容总结

以上是互联网集市为您收集整理的java jdbc 连接mysql数据库 实现增删改查全部内容，希望文章能够帮你解决java jdbc 连接mysql数据库 实现增删改查所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端