1 package cn.itcast.domain;
2
3 import java.util.Date;
4
5 public class User {
6
7 private int id;
8 private String name;
9 private Date birthday;
10 private float money;
11
12 public int getId() {
13 return id;
14 }
15
16 public void setId(int id) {
17 this.id = id;
18 }
19
20 public String getName() {
21 return name;
22 }
23
24 public void setName(String name) {
25 this.name = name;
26 }
27
28 public Date getBirthday() {
29 return birthday;
30 }
31
32 public void setBirthday(Date birthday) {
33 this.birthday = birthday;
34 }
35
36 public float getMoney() {
37 return money;
38 }
39
40 public void setMoney(float money) {
41 this.money = money;
42 }
43
44 }
User
1 package cn.itcast.dao;
2
3 import java.sql.SQLException;
4
5 import cn.itcast.domain.User;
6
7 public interface UserDao {
8
9 public void addUser(User user) throws SQLException;
10
11 public User getUser(int userId);
12
13 public void update(User user);
14
15 public void delete(User user);
16
17 public User findUser(String userName,String password);
18
19
20
21 }
UserDao
1 package cn.itcast.dao.impl;
2
3 import java.sql.Connection;
4 import java.sql.Date;
5 import java.sql.PreparedStatement;
6 import java.sql.ResultSet;
7 import java.sql.SQLException;
8 import java.sql.Statement;
9
10 import cn.itcast.dao.UserDao;
11 import cn.itcast.domain.User;
12 import cn.itcast.exception.DaoException;
13 import cn.itcast.jdbc.jdbcUtils;
14
15 public class UserDaoJdbcImpl implements UserDao {
16
17 @Override
18 public void addUser(User user) throws DaoException {
19
20 Connection conn = null;
21 PreparedStatement ps = null;
22 ResultSet rs = null;
23
24 try {
25 // 建立连接
26 conn = jdbcUtils.getConnection();
27
28 String sql = "insert into user(name,birthday,money) values(?,?,?)";
29 ps = conn.prepareStatement(sql);
30
31 ps.setString(1, user.getName());
32 ps.setDate(2, new java.sql.Date(user.getBirthday().getTime()));
33 ps.setFloat(3, user.getMoney());
34
35 ps.executeUpdate();
36
37 } catch (SQLException e) {
38 throw new DaoException(e.getMessage(), e);
39 } finally {
40 jdbcUtils.free(rs, ps, conn);
41 }
42
43 }
44
45 @Override
46 public User getUser(int userId) {
47 Connection conn = null;
48 PreparedStatement ps = null;
49 ResultSet rs = null;
50 User user = null;
51
52 try {
53 conn = jdbcUtils.getConnection();
54 String sql = "select id,name,money,birthday from user where id = ?";
55 ps = conn.prepareStatement(sql);
56 ps.setInt(1, userId);
57 rs = ps.executeQuery();
58
59 while (rs.next()) {
60
61 user = mappingUser(rs);
62
63 }
64
65 } catch (SQLException e) {
66 throw new DaoException(e.getMessage());
67 } finally {
68 jdbcUtils.free(rs, ps, conn);
69 }
70
71 return user;
72 }
73
74 public User mappingUser(ResultSet rs) throws SQLException {
75 User user = new User();
76 user.setId(rs.getInt("id"));
77 user.setName(rs.getString("name"));
78 user.setMoney(rs.getFloat("money"));
79 user.setBirthday(rs.getDate("birthday"));
80 return user;
81 }
82
83 @Override
84 public void update(User user) {
85 Connection conn = null;
86 PreparedStatement ps = null;
87 ResultSet rs = null;
88
89 try {
90 conn = jdbcUtils.getConnection();
91 String sql = "update user set name = ?,money=? where id=?";
92 ps = conn.prepareStatement(sql);
93 ps.setString(1, user.getName());
94 //ps.setDate(2, new java.sql.Date(user.getBirthday().getTime()));
95 ps.setFloat(2, user.getMoney());
96 ps.setInt(3, user.getId());
97
98 ps.executeUpdate();
99
100 } catch (SQLException e) {
101 new DaoException(e.getMessage());
102 } finally {
103 jdbcUtils.free(rs, ps, conn);
104 }
105
106 }
107
108 @Override
109 public void delete(User user) {
110
111 Connection conn = null;
112 Statement st = null;
113 ResultSet rs = null;
114
115 try {
116 conn = jdbcUtils.getConnection();
117 st = conn.createStatement();
118 String sql = "delete from user where id=" + user.getId();
119 st.executeUpdate(sql);
120
121 } catch (SQLException e) {
122 throw new DaoException(e.getMessage());
123 } finally {
124 jdbcUtils.free(rs, st, conn);
125 }
126
127 }
128
129 @Override
130 public User findUser(String userName, String password) {
131
132 Connection conn = null;
133 PreparedStatement ps = null;
134 ResultSet rs = null;
135 User user = null;
136
137 try {
138 conn = jdbcUtils.getConnection();
139 String sql = "select id,name,money,birthday from user where name = ?";
140 ps = conn.prepareStatement(sql);
141 ps.setString(1, userName);
142 rs = ps.executeQuery();
143
144 while (rs.next()) {
145 user = mappingUser(rs);
146 }
147
148 } catch (SQLException e) {
149 throw new DaoException(e.getMessage());
150 } finally {
151 jdbcUtils.free(rs, ps, conn);
152 }
153
154 return user;
155 }
156
157 }
UserDaoJdbcImpl
1 package cn.itcast.exception;
2
3 public class DaoException extends RuntimeException {
4
5 private static final long serialVersionUID = 1L;
6
7 public DaoException() {
8 super();
9 // TODO Auto-generated constructor stub
10 }
11
12 public DaoException(String message, Throwable cause) {
13 super(message, cause);
14 // TODO Auto-generated constructor stub
15 }
16
17 public DaoException(String message) {
18 super(message);
19 // TODO Auto-generated constructor stub
20 }
21
22 public DaoException(Throwable cause) {
23 super(cause);
24 // TODO Auto-generated constructor stub
25 }
26
27 }
DaoException
1 package cn.itcast.jdbc;
2
3 import java.sql.Connection;
4 import java.sql.DriverManager;
5 import java.sql.ResultSet;
6 import java.sql.SQLException;
7 import java.sql.Statement;
8
9 public class jdbcUtils {
10
11 private static String url = "jdbc:mysql://localhost:3306/jdbc";
12 private static String user = "root";
13 private static String password = "123";
14
15 private jdbcUtils() {
16
17 }
18
19 static {
20 try {
21 Class.forName("com.mysql.jdbc.Driver");
22 } catch (ClassNotFoundException e) {
23 e.printStackTrace();
24 }
25 }
26
27 public static Connection getConnection() throws SQLException {
28 return DriverManager.getConnection(url, user, password);
29 }
30
31 public static void free(ResultSet rs, Statement st, Connection conn) {
32
33 try {
34 if (rs != null)
35 rs.close();
36 } catch (SQLException e) {
37 e.printStackTrace();
38 } finally {
39
40 try {
41 if (st != null)
42 st.close();
43 } catch (SQLException e) {
44 e.printStackTrace();
45 } finally {
46
47 try {
48 if (conn != null)
49 conn.close();
50 } catch (SQLException e) {
51 e.printStackTrace();
52 }
53 }
54
55 }
56
57 }
58 }
jdbcUtils
1 package cn.itcast.dao;
2
3 import java.sql.SQLException;
4 import java.util.Date;
5
6 import cn.itcast.dao.impl.UserDaoJdbcImpl;
7 import cn.itcast.domain.User;
8
9 public class UserTest {
10
11 /**
12 * @param args
13 * @throws SQLException
14 */
15 public static void main(String[] args) throws SQLException {
16
17 UserDao userDao = new UserDaoJdbcImpl();
18
19 //User user = new User();
20 //user.setBirthday(new Date());
21 //user.setName("dao name1");
22 //user.setMoney(1000.0f);
23
24 // userDao.addUser(user);
25 //
26 // User u = userDao.findUser(user.getName(),null);
27 // System.out.println(u.getId());
28
29 User u = userDao.getUser(1);
30
31 u.setMoney(2000.0f);
32 userDao.update(u);
33
34 User u1 = userDao.getUser(1);
35 userDao.delete(u1);
36
37 }
38
39 }
UserTest
时间： 2024-12-22 22:11:41