empoldercompany.java

网上虚拟社区

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class EmpolderCompany extends Virtualperson{
	
	public EmpolderCompany(String name,String address,String password,String account,String pin){
		super(name, address, password,account, pin);
	}
	public synchronized boolean bid(String name,Double price){
		try{
		    Connection conn = dbOperator.getConnection();
			PreparedStatement stat = conn.prepareStatement("SELECT * FROM Software WHERE itsname = ?and settled = 0 ");
			stat.setString(1, name);
			ResultSet result = stat.executeQuery();
			if(result.next()){
				System.out.println("The Software is not exist or had been bided!");				
			}
			else if(price>result.getDouble("price")){
				String query = "UPDATE Software"
					+ " SET price = ?"
					+ " WHERE ID = ?";
				stat =conn.prepareStatement(query);
				stat.setDouble(1, price);	
				stat.setDouble(2,  result.getDouble("ID"));
				stat.executeUpdate();
				conn.close();
				addOperator("bid",price,result.getString("needer"),name);
				return true;
			}
			else
				System.out.println("Your price is too low!");
			addOperator("bid",price,result.getString("needer"),name);
			conn.close();
			return false;
		}
		catch(SQLException ex){
			System.out.println(ex);
			return false;
		}
	}
	
	public synchronized boolean add() {
		try {
			Connection conn = dbOperator.getConnection();
			PreparedStatement stat = conn
					.prepareStatement("SELECT * FROM Virtualperson WHERE Virtualname = ?");
			stat.setString(1, this.GetName());
			ResultSet result = stat.executeQuery();
			if (!result.next()) {
				System.out.println("The Name has already exist!");
				return false;
			} else {
				stat =conn.prepareStatement("insert into Virtualperson(Password, Virtualname ,Address,Account,genere) values(?, ?,?,?,2)");
				stat.setString(1, this.GetPassword());
				stat.setString(2, this.GetName());
				stat.setString(3, this.GetAddress());
				stat.setString(4, this.GetAccount());
				stat.executeUpdate();
			}
			conn.close();
			addOperator("add", 0, this.GetName(), "EmpolderCompany");
			return true;
		} catch (SQLException ex) {
			System.out.println(ex);
			return false;
		}
	}
}