1、 this.id = id; public void setName(String name) this.name = name; public void setPassword(String password) this.password = password; public void setAge(int age) this.age = age; public void setEmail(String email) this.email = email; public String getId() return this.id; public String getName() return
2、 this.name; public String getPassword() return this.password; public int getAge() return this.age; public String getEmail() return this.email; Override public String toString() return Person age= + age + , email= + email + , id= + id + , name= + name + , password= + password + ; 工厂列DAOFactory.javapa
3、ckage com.connect.t01.factory;import com.connect.t01.dao.PersonDAO;import com.connect.t01.dao.PersonDAOImpl;public class DAOFactory public static PersonDAO getPersonDAOInstance() return new PersonDAOImpl();抽象类PersonDAO.javapackage com.connect.t01.dao;import java.util.*;import com.connect.t01.vo.Pers
4、on;/ 规定出了操作person表在此项目里的全部方法 public interface PersonDAO / 增加操作 public void insert(Person person) throws Exception; / 修改操作 public void update(Person person) throws Exception; / 删除操作 public void delete(String id) throws Exception; / 按ID查询操作 public Person queryById(String id) throws Exception; / 查询全部 p
5、ublic List queryAll() throws Exception; / 模糊查询 public List queryByLike(String cond) throws Exception;抽象类的实现PersonDAOImpl.javaJava代码import java.sql.*;import com.connect.t01.db.DataBaseConnection;/ 此类需要完成具体的数据库操作,需要JDBC代码 public class PersonDAOImpl implements PersonDAO public void insert(Person person
6、) throws Exception String sql = INSERT INTO person (id,name,password,age,email) VALUES (?,?) PreparedStatement pstmt = null; DataBaseConnection dbc = null; / 下面是针对数据库的具体操作 try / 连接数据库 dbc = new DataBaseConnection(); pstmt = dbc.getConnection().prepareStatement(sql); pstmt.setString(1, person.getId()
7、; pstmt.setString(2, person.getName(); pstmt.setString(3, person.getPassword(); pstmt.setInt(4, person.getAge(); pstmt.setString(5, person.getEmail(); / 进行数据库更新操作 pstmt.executeUpdate(); pstmt.close(); catch (Exception e) throw new Exception(操作出现异常); finally / 关闭数据库连接 dbc.close(); public void update(
8、Person person) throws Exception UPDATE person SET name=?,password=?,age=?,email=? WHERE id=? pstmt.setString(1, person.getName(); pstmt.setString(2, person.getPassword(); pstmt.setInt(3, person.getAge(); pstmt.setString(4, person.getEmail(); pstmt.setString(5, person.getId(); public void delete(Stri
9、ng id) throws Exception DELETE FROM person WHERE id=? pstmt.setString(1, id); public Person queryById(String id) throws Exception Person person = null;SELECT id,name,password,age,email FROM person WHERE id=? / 进行数据库查询操作 ResultSet rs = pstmt.executeQuery(); if (rs.next() / 查询出内容,之后将查询出的内容赋值给person对象
10、person = new Person(); person.setId(rs.getString(1); person.setName(rs.getString(2); person.setPassword(rs.getString(3); person.setAge(rs.getInt(4); person.setEmail(rs.getString(5); rs.close(); return person; public List queryAll() throws Exception List all = new ArrayList();SELECT id,name,password,
11、age,email FROM person while (rs.next() Person person = new Person(); / 将查询出来的数据加入到List对象之中 all.add(person); return all; public List queryByLike(String cond) throws Exception SELECT id,name,password,age,email FROM person WHERE name LIKE ? or email LIKE ? / 设置模糊查询条件 pstmt.setString(1, % + cond + pstmt
12、.setString(2, 数据库操作类DataBaseConnection.javapackage com.connect.t01.db;/主要功能就是连接数据库、关闭数据库 public class DataBaseConnection private final String DBDRIVER = oracle.jdbc.driver.OracleDriver private final String DBURL = jdbc:oracle:thin:192.168.0.99:1521:denver private final String DBUSER = zzw private fi
13、nal String DBPASSWORD = private Connection conn = null; public DataBaseConnection() Class.forName(DBDRIVER); this.conn = DriverManager.getConnection(DBURL, DBUSER, DBPASSWORD); / 取得数据库连接 public Connection getConnection() return this.conn; / 关闭数据库连接 public void close() this.conn.close(); public stati
14、c void main(String args) DataBaseConnection aa = new DataBaseConnection(); System.out.println(aa.getConnection();测试类Main.javapackage com.connect.t01;import java.util.Iterator;import java.util.List;import com.connect.t01.factory.DAOFactory; * jdbc操作oracle数据库(增删改查) * data 2013-11-29public class Main S
15、uppressWarnings(unchecked) public static void main(String args) Person person = new Person(); person.setId(002 person.setName( person.setPassword( person.setAge(20); person.setEmail(eleven /通过工厂获得实例 PersonDAO ps = DAOFactory.getPersonDAOInstance(); /PersonDAO ps = new PersonDAOImpl(); /增加测试/ try / ps.insert(person);/ System.out.println(插入数据库成功/ catch (Exception e) / e.printStackTrace();/ / /删除测试/ ps.delete(0001删除成功 /修改测试