startprocess.java

java版虚拟社区,在mysql上运行.

package serverpack;

import java.sql.*;
import java.sql.Connection;
import java.sql.Statement;

public class StartProcess {
	
	private Connection conn;
	private Statement stat;
	private Monitor mo;
	
	public StartProcess(Connection c,Monitor m){conn = c;mo = m;}
	
	public boolean RegSoftSell(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				System.out.println(mm.GetMes(0)+" ID already exsit");
				mo.appendmessage(mm.GetMes(0)+" ID already exsit"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				result.close();
				stat.close();
				return true; 
			}
			else
			{
				stat.execute("INSERT INTO login VALUES(NULL,'softsell','"+mm.GetMes(0)+"'," +
						"'"+mm.GetMes(1)+"','"+mm.GetMes(3)+"',NULL,'N')");
				stat.execute("CREATE TABLE "+"softsell_all_"+mm.GetMes(0)+"(" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"softname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"description VARCHAR(100) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"retail FLOAT ," +
						"stored INT DEFAULT 0," +
						"sold INT DEFAULT 0," +
						"develop_id VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"develop_name VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci)");
				stat.execute("CREATE TABLE "+"softsell_feedback_"+mm.GetMes(0)+" (" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"softname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"develop_id VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"develop_name VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"feedback VARCHAR(100) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"customer_name VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci)");
				stat.execute("CREATE TABLE "+"softsell_customer_"+mm.GetMes(0)+" (" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"softname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"customer_id VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"customer_name VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"retail FLOAT DEFAULT 0," +
				//		"time DATETIME)");
						"time TIMESTAMP(14))");
				mm.SetType("true");
				mm.SetNum(0);
				stat.close();
				System.out.println(mm.GetMes(0)+" RegSoftSell success");
				mo.appendmessage(mm.GetMes(0)+" RegSoftSell success"+"\n");
				return true;     
			}
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean RegCustomer(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				System.out.println(mm.GetMes(0)+" ID already exsit");
				mo.appendmessage(mm.GetMes(0)+" ID already exsit"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				result.close();
				stat.close();
				return true; 
			}
			else
			{
				stat.execute("INSERT INTO login VALUES(NULL,'customer','"+mm.GetMes(0)+"'," +
						"'"+mm.GetMes(1)+"','"+mm.GetMes(3)+"',NULL,'N')");
				mm.SetType("true");
				mm.SetNum(0);
				stat.close();
				System.out.println(mm.GetMes(0)+" RegCustomer success");
				mo.appendmessage(mm.GetMes(0)+" RegCustomer success"+"\n");
				return true;     
			}
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean RegSoftDevelp(MyMessage mm)
	{
		try
		{ 
			System.out.println(mm.GetType());
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				System.out.println(mm.GetMes(0)+" ID already exsit");
				mo.appendmessage(mm.GetMes(0)+" ID already exsit"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				result.close();
				stat.close();
				return true; 
			}
			else
			{
				stat.execute("INSERT INTO login VALUES(NULL,'softdevelop','"+mm.GetMes(0)+"'," +
						"'"+mm.GetMes(1)+"','"+mm.GetMes(3)+"',NULL,'N')");
				stat.execute("CREATE TABLE "+"softdevelop_all_"+mm.GetMes(0)+" (" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"softname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"description VARCHAR(100) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"time TIMESTAMP(14)," +
						"cost FLOAT DEFAULT 0," +
						"retail FLOAT DEFAULT 0," +
						"if_done VARCHAR(5) DEFAULT 'N',"+
						"ordered INT DEFAULT 0," +
						"sold INT DEFAULT 0," +
						"profit FLOAT DEFAULT 0," +
						"if_invested VARCHAR(5) DEFAULT 'N',"+
						"investor VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci)");
			
				mm.SetType("true");
				mm.SetNum(0);
				stat.close();
				System.out.println(mm.GetMes(0)+" RegSoftDevelp success");
				mo.appendmessage(mm.GetMes(0)+" RegSoftDevelp success"+"\n");
				return true;     
			}
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean RegInvestCorp(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				System.out.println(mm.GetMes(0)+" ID already exsit");
				mo.appendmessage(mm.GetMes(0)+" ID already exsit"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				result.close();
				stat.close();
				return true; 
			}
			else
			{
				stat.execute("INSERT INTO login VALUES(NULL,'investcorp','"+mm.GetMes(0)+"'," +
						"'"+mm.GetMes(1)+"','"+mm.GetMes(3)+"',NULL,'N')");
				stat.execute("CREATE TABLE "+"investcorp_myinvest_"+mm.GetMes(0)+" (" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"softname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"description VARCHAR(100) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"time TIMESTAMP(14)," +
						"account FLOAT DEFAULT 0," +
						"retail FLOAT DEFAULT 0," +
						"bider_id VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"bider_name VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"if_done VARCHAR(5) DEFAULT 'N'," +
						"profit FLOAT DEFAULT 0)");
				mm.SetType("true");
				mm.SetNum(0);
				stat.close();
				System.out.println(mm.GetMes(0)+" RegInvestCorp success");
				mo.appendmessage(mm.GetMes(0)+" RegInvestCorp success"+"\n");
				return true;     
			}
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean RegRestaurant(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement();
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				System.out.println(mm.GetMes(0)+" ID already exsit");
				mo.appendmessage(mm.GetMes(0)+" ID already exsit"+"\n");
				mm.SetType("false");
				mm.SetNum(0);
				result.close();
				stat.close();
				return true; 
			}
			else
			{
				stat.execute("INSERT INTO login VALUES(NULL,'restaurant','"+mm.GetMes(0)+"'," +
						"'"+mm.GetMes(1)+"','"+mm.GetMes(3)+"',NULL,'N')");
				stat.execute("CREATE TABLE "+"restaurant_menu_"+mm.GetMes(0)+" (" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"foodname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"price FLOAT DEFAULT 0)");
				stat.execute("CREATE TABLE "+"restaurant_customer_"+mm.GetMes(0)+" (" +
						"ind INTEGER NOT NULL AUTO_INCREMENT," +
						"PRIMARY KEY (ind)," +
						"customer_id VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"customer_name VARCHAR(20) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"foodname VARCHAR(45) CHARACTER SET gbk COLLATE gbk_chinese_ci," +
						"price FLOAT DEFAULT 0," +
						"time TIMESTAMP(14))");
				mm.SetType("true");
				mm.SetNum(0);
				stat.close();
				System.out.println(mm.GetMes(0)+" RegRestaurant success");
				mo.appendmessage(mm.GetMes(0)+" RegRestaurant success"+"\n");
				return true;     
			}
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean Login(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			if(result.next())
			{
				
				if(result.getString("password").equals(mm.GetMes(1)))
				{
					if("N".equals(result.getString("if_log")))
					{
						result.updateNull("time");
						result.updateString("if_log", "Y");
						mm.SetType("LOGOK");	
						mm.SetNum(1);
						mm.SetMes(result.getString("type"), 0);
						System.out.println(result.getString("id")+" Login success");
						mo.appendloger(result.getString("id")+"\n");
						mo.appendmessage(result.getString("id")+" Login success"+"\n");
						result.updateRow();
					}
					else
					{
						mm.SetType("LOGED");	
						mm.SetNum(0);
						System.out.println(result.getString("id")+" can not log again");
						mo.appendmessage(result.getString("id")+" can not log again"+"\n");
					}
				}
				else
				{
					mm.SetType("WPASS");	
					mm.SetNum(0);
					System.out.println(result.getString("id")+" Wrong password");
					mo.appendmessage(result.getString("id")+" Wrong password"+"\n");
				}
				
				result.close();
				stat.close();
				return true; 
			}
			else
			{
				
				mm.SetType("WID");
				mm.SetNum(0);
				System.out.println("illegal id");
				mo.appendmessage("Illegal id"+"\n");
				stat.close();
				return true;     
			}
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean Left(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE id = '"+mm.GetMes(0)+"'");
			result.next();
			result.updateString("if_log", "N");
			System.out.println(result.getString("id")+" Left");
			result.updateRow();
					
			result.close();
			stat.close();
			return true; 
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
	public boolean Init(MyMessage mm)
	{
		try
		{ 
			stat = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
			ResultSet result = stat.executeQuery("SELECT * FROM login WHERE if_log = 'Y'");
			
			while(result.next())
			{
				result.updateString("if_log", "N");
				result.updateRow();
			}
			System.out.println("Database init success");	
			mo.appendmessage("Database init success"+"\n");
			result.close();
			stat.close();
			return true; 
		}
		catch(SQLException e) 
	    { 
	    	System.out.println("SQLException"); 
	        e.printStackTrace(); 
	    }
		return false;
	}
}