postdb.java

含有图形化界面

package com.zsf.manager;

import java.sql.*;
import java.util.ArrayList;
import java.util.Iterator;

public class PostDB {
	private final MyDB mydb;
	
	public PostDB(MyDB mydb) {
		this.mydb = mydb;
	}

	public void savePost(Post post) throws SQLException {
		mydb.openConnection();
		String sql = "INSERT INTO contacts (FirstName,LastName,Telephone,Role) VALUES('" +
						post.getfirstname() + "','" +
						post.getlastname() + "','"+post.gettelephone()+"','"+
						post.getrole()+"')";
		mydb.executeUpdate(sql);
		mydb.closeConnection();
	}
	
	public void deletePost(Post post) throws SQLException{
		mydb.openConnection();
		String sql = "DELETE FROM contacts WHERE ID="+Integer.parseInt(post.getid());
		mydb.executeUpdate(sql);
		mydb.closeConnection();
	}
	
	public void updatePost(Post post) throws SQLException{
		mydb.openConnection();
		String sql = "UPDATE contacts"+
					" SET FirstName="+"'"+post.getfirstname()+"'"+" , LastName="+"'"+
					post.getlastname()+"'"+" , Telephone="+"'"+post.gettelephone()+"'"+
					" WHERE ID="+Integer.parseInt(post.getid());
		mydb.executeUpdate(sql);
		mydb.closeConnection();
	}
	
	public Iterator selectPost(String role) throws SQLException{
		ArrayList<Post> posts = new ArrayList<Post>();		
		mydb.openConnection();
		String sql = "SELECT * FROM contacts WHERE Role="+"'"+role+"'";
		ResultSet rs = mydb.executeQuery(sql);

		while (rs.next()) {			
			Post post = new Post();
			post.setid(rs.getInt("ID"));
			post.setfirstname(rs.getString("FirstName"));			
			post.setlastname(rs.getString("LastName"));
			post.settelephone(rs.getString("Telephone"));			
			posts.add(post);
		}	
		
		rs.close();
		mydb.closeConnection();
		
		return posts.iterator();
	}
	
	
	public Iterator getAllPosts() throws SQLException {
		
		ArrayList<Post> posts = new ArrayList<Post>();		
		mydb.openConnection();
		String sql = "SELECT * FROM contacts";
		ResultSet rs = mydb.executeQuery(sql);

		while (rs.next()) {			
			Post post = new Post();
			post.setid(rs.getInt("ID"));
			post.setfirstname(rs.getString("FirstName"));			
			post.setlastname(rs.getString("LastName"));
			post.settelephone(rs.getString("Telephone"));			
			posts.add(post);
		}
		
		rs.close();
		mydb.closeConnection();
		
		return posts.iterator();
	}
	
	public int getCountOfRecords() throws SQLException
	{
		mydb.openConnection();
		String sql="SELECT * FROM contacts";
		ResultSet rs = mydb.executeQuery(sql);
		int counter=0;
		while (rs.next()) 
				counter++;		
		rs.close();
		mydb.closeConnection();
		return counter;
	}
}