?? people.java
字號:
package com.jack.dwr.simple;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.ArrayList;import java.util.List;/** * A container for a set of people * * @author jackzhangyunjie */public class People { private Connection conn; /** * 構造函數,同時初始化建立與數據庫的連接 */ public People() { try { conn = DBConnection.getConnectionMySqlDB("3306", "jackdemo", "root", "root"); } catch (Exception e) { e.printStackTrace(); } } /** * 刪除一個用戶 * * @param person * 要刪除的用戶 * */ public void deletePerson(Person person) throws Exception { String sql = "delete from jackdemo1 where id=?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1, person.getId()); //更新數據庫操作 pstmt.executeUpdate(); //關閉預編譯和數據庫連接 pstmt.close(); conn.close(); } /** * 更新用戶信息 * @param person 要進行更新的用戶對象 * @throws Exception */ public void updatePerson(Person person) throws Exception { String sql = "update jackdemo1 set name=?,age=?,address=? where id=?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, person.getName()); pstmt.setInt(2, person.getAge()); pstmt.setString(3, person.getAddress()); pstmt.setInt(4, person.getId()); //更新數據庫操作 pstmt.executeUpdate(); //關閉預編譯和數據庫連接 pstmt.close(); conn.close(); } /** * 得到全部的人員信息 * * @return 返回一個包含人員的List * @throws SQLException */ @SuppressWarnings("unchecked") public List getAllPerson() throws SQLException { List list = new ArrayList(); String sql = "select * from jackdemo1"; Statement st = conn.createStatement(); //查詢數據庫,得到所有人員信息 ResultSet rs = st.executeQuery(sql); while (rs.next()) { Person person = new Person(); person.setId(rs.getInt("id")); person.setName(rs.getString("name")); person.setAge(rs.getInt("age")); person.setAddress(rs.getString("address")); list.add(person); } return list; } /** * 添加人員 * * @param person * 要添加的人員的信息 */ public void addPerson(Person person) throws Exception { String sql = "insert into jackdemo1(name,age,address) values(?,?,?)"; PreparedStatement pstmt = conn.prepareStatement(sql); //設置人員信息 pstmt.setString(1, person.getName()); pstmt.setInt(2, person.getAge()); pstmt.setString(3, person.getAddress()); //更新數據庫操作 pstmt.executeUpdate(); //關閉預編譯和數據庫連接 pstmt.close(); conn.close(); }}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -