Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class PersonDAO extends DAO{
- public PersonDAO() throws Exception {
- super();
- }
- public void addPerson(Person thePerson) throws Exception{
- PreparedStatement myStmt = null;
- try {
- // prepare statement
- myStmt = myConn.prepareStatement("INSERT INTO person"
- + " (person_id, last_name, first_name, fk_county_id)"
- + " values (?, ?, ?, ?)");
- // set param
- myStmt.setString(1, thePerson.getId());
- myStmt.setString(2, thePerson.getLastName());
- myStmt.setString(3, thePerson.getFirstName());
- myStmt.setString(4, thePerson.getCountyId());
- myStmt.executeUpdate();
- } catch (SQLSyntaxErrorException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } finally {
- DAO.close(myStmt);
- }
- }
- public void deletePerson(int personId) throws SQLException {
- PreparedStatement myStmt = null;
- try {
- // prepare statement
- myStmt = myConn.prepareStatement("DELETE FROM person WHERE person_id=?");
- // set param
- myStmt.setInt(1, personId);
- // execute SQL
- myStmt.executeUpdate();
- }
- finally {
- close(myStmt);
- }
- }
- public List<Person> getAllObjects() throws Exception {
- List<Person> list = new ArrayList<>();
- Statement myStm = null;
- ResultSet myRs = null;
- try {
- myStm = myConn.createStatement();
- myRs = myStm.executeQuery("SELECT * FROM PERSON");
- while (myRs.next()) {
- Person tempPerson = convertRowToPerson(myRs);
- list.add(tempPerson);
- }
- return list;
- } finally {
- close(myStm, myRs);
- }
- }
- public List<Person> searchObject(String lastName) throws Exception {
- List<Person> list = new ArrayList<>();
- PreparedStatement myStm = null;
- ResultSet myRs = null;
- String search = "%";
- search += lastName;
- search += "%";
- try {
- myStm = myConn
- .prepareStatement("SELECT * FROM person WHERE last_name like ?");
- myStm.setString(1, search);
- myRs = myStm.executeQuery();
- while (myRs.next()) {
- Person tempPerson = convertRowToPerson(myRs);
- list.add(tempPerson);
- }
- return list;
- } finally {
- close(myStm, myRs);
- }
- }
- private Person convertRowToPerson(ResultSet myRs) throws SQLException {
- String id = myRs.getString("Person_ID");
- String lastName = myRs.getString("Last_name");
- String firstName = myRs.getString("First_name");
- String countyId = myRs.getString("FK_County_ID");
- Person tempPerson = new Person(id, lastName, firstName, countyId);
- return tempPerson;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement