Java 数据库编程之mysql(二)
throws Exception {
boolean flag = false;
PreparedStatement pstmt = null;
String sql = "INSERT INTO user(name,sex,birthday) VALUES ( , , ) ";
try {
pstmt = this.conn.prepareStatement(sql);
pstmt.setString(1, user.getName()); // 所有的内容从user类中取出
pstmt.setString(2, user.getSex()); // 所有的内容从user类中取出
pstmt.setDate(3, new java.sql.Date(user.getBirthday().getTime()));
if (pstmt.executeUpdate() > 0) {// 至少已经更新了一行
flag = true;
}
} catch (Exception e) {
throw e;
} finally { // 不管如何抛出，最终肯定是要进行数据库的关闭操作的
if (pstmt != null) {
try {
pstmt.close();
} catch (Exception e1) {
}
}
}
return flag;
}
@Override
public boolean doDelete(int id) throws Exception {
boolean flag = false;
PreparedStatement pstmt = null;
String sql = "DELETE FROM user WHERE id= ";
try {
pstmt = this.conn.prepareStatement(sql);
pstmt.setInt(1, id); // 所有的内容从user类中取出
if (pstmt.executeUpdate() > 0) {// 至少已经更新了一行
flag = true;
}
} catch (Exception e) {
throw e;
} finally { // 不管如何抛出，最终肯定是要进行数据库的关闭操作的
if (pstmt != null) {
try {
pstmt.close();
} catch (Exception e1) {
}
}
}
return flag;
}
@Override
public boolean doUpdate(User user) throws Exception {
boolean flag = false;
PreparedStatement pstmt = null;
String sql = "UPDATE user SET name= ,sex= ,birthday= WHERE id= ";
try {
pstmt = this.conn.prepareStatement(sql);
pstmt.setString(1, user.getName()); // 所有的内容从user类中取出
pstmt.setString(2, user.getSex()); // 所有的内容从user类中取出
pstmt.setDate(3, new java.sql.Date(user.getBirthday().getTime()));
pstmt.setInt(4, user.getId());
if (pstmt.executeUpdate() > 0) {// 至少已经更新了一行
flag = true;
}
} catch (Exception e) {
throw e;
} finally { // 不管如何抛出，最终肯定是要进行
数据库的关闭操作的
if (pstmt != null) {
try {
pstmt.close();
} catch (Exception e1) {
}
}
}
return flag;
}
@Override
public List
findAll(String keyWord) throws Exception {
List
all = new ArrayList
(); PreparedStatement pstmt = null; String sql = "SELECT id,name,sex,birthday FROM user WHERE name LIKE OR sex LIKE OR birthday LIKE "; try { pstmt = this.conn.prepareStatement(sql); pstmt.setString(1, "%" + keyWord + "%"); pstmt.setString(2, "%" + keyWord + "%"); pstmt.setString(3, "%" + keyWord + "%"); ResultSet rs = pstmt.executeQuery(); // 执行查询操作 while (rs.next()) { User user = new User(); user.setId(rs.getInt(1)); user.setName(rs.getString(2)); user.setSex(rs.getString(3)); user.setBirthday(rs.getDate(4)); all.add(user); // 所有的内容向集合中插入 } rs.close(); } catch (Exception e) { throw e; } finally { // 不管如何抛出，最终肯定是要进行数据库的关闭操作的 if (pstmt != null) { try { pstmt.close(); } catch (Exception e1) { } } } return all; } @Override public User findById(int id) throws Exception { User user = null; PreparedStatement pstmt = null; String sql = "SELECT id,name,sex,birthday FROM user WHERE id= "; try { pstmt = this.conn.prepareStatement(sql); pstmt.setInt(1, id); ResultSet rs = pstmt.executeQuery(); // 执行查询操作 if (rs.next()) { user = new User(); user.setId(rs.getInt(1)); user.setName(rs.getString(2)); user.setSex(rs.getString(3)); user.setBirthday(rs.getDate(4)); } rs.close(); } catch (Exception e) { throw e; } finally { // 不管如何抛出，最终肯定是要进行数据库的关闭操作的 if (pstmt != null) { try { pstmt.close(); } catch (Exception e1) { } } } return user; } }