dealmessage.java

一个用于实现不同数据库数据同步的程序

import java.io.*;
import java.lang.*;

public class dealMessage
{
	public String cutMessage(String m,int start,int end)
	{
		String cm="";
		char buf[]=new char[end-start];
		m.getChars(start,end,buf,0);
		cm=String.valueOf(buf);
		cm=cm.trim();
		return cm;
	}

	public String changingSQL(String ss)
	{
		int start=0,mid=0;
		String s=ss;
		String sqlSentence="",temp="",sno="";

		mid=s.indexOf("\t");
		temp=cutMessage(s,start,mid);

		start=mid;
		mid=s.length();
		s=cutMessage(s,start,mid);

		start=0;
		mid=s.indexOf("\t");
		if(mid==-1)
		{
			sno=s;
		}
		else
		{
			sno=cutMessage(s,start,mid);
		}

		if(temp.equals("alter"))
		{
			start=mid;
			mid=s.length();
			s=cutMessage(s,start,mid);
			sqlSentence="update card set ";
			while(true)
			{
				start=0;
				mid=s.indexOf("\t");
				temp=cutMessage(s,start,mid);
				sqlSentence+=temp+"='";

				start=mid;
				mid=s.length();
				s=cutMessage(s,start,mid);

				start=s.indexOf("\t");
				mid=s.length();
				s=cutMessage(s,start,mid);

				start=0;
				mid=s.indexOf("\t");
				if(mid!=-1)
				{
					temp=cutMessage(s,start,mid);
					sqlSentence+=temp+"',";
					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);
				}
				else
				{
					sqlSentence+=s+"' ";
					break;
				}
			}
			sqlSentence+="where SNUMBER='"+sno+"'";
								
		}
		else
		{
			if(temp.equals("new"))
			{
				start=mid;
				mid=s.length();
				s=cutMessage(s,start,mid);

				sqlSentence="insert into card values('"+sno+"','";

				start=0;
				mid=s.indexOf("\t");
				while(true)
				{
					temp=cutMessage(s,start,mid);
					sqlSentence+=temp+"','";

					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=0;
					mid=s.indexOf("\t");
					if(mid==-1)
					{						
						sqlSentence+=s+"')";
						break;
					}
				}
								
			}
			else
			{
				if(temp.equals("delete"))
				{
					sqlSentence="delete from card where SNUMBER='"+sno+"'";
				}
			}
							
		}

		return sqlSentence;
	}

	public String chineseOutput(int i,String cs)
	{
		int start=0,mid=0,newstate=0,b=0;
		String s="",temp="",temp2="",returnMesg="";
		s=cs;

		mid=s.indexOf("\t");
		temp=cutMessage(s,start,mid);

		if(temp.equals("Update"))
		{
			returnMesg="\nLocal Database Updated.\nTime of Updated(or Found out): \t";

			start=mid;
			mid=s.length();
			s=cutMessage(s,start,mid);
			
			start=0;
			mid=s.indexOf("\t");
			temp=cutMessage(s,start,mid);
			returnMesg+=temp;

			start=mid;
			mid=s.length();
			s=cutMessage(s,start,mid);

			if(i==1)
			{
				returnMesg+="\nTime of Complete synchronism in DHDS: \t";
			}
			else
			{
				returnMesg+="\nSum of the Database which have synchronized: \t";
			}			
			returnMesg+=s+"\nUpdata Detail: ";
		}
		else
		{
			if(temp.equals("alter"))
			{
				start=mid;
				mid=s.length();
				s=cutMessage(s,start,mid);

				start=0;
				mid=s.indexOf("\t");
				temp=cutMessage(s,start,mid);
				returnMesg="    Student No. "+temp+" Altered\t=>    ";

				start=mid;
				mid=s.length();
				s=cutMessage(s,start,mid);

				start=0;
				mid=s.indexOf("\t");
				while(mid!=-1)
				{
					temp=cutMessage(s,start,mid);

					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=s.indexOf("\t");
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=0;
					mid=s.indexOf("\t");
					if(mid!=-1)
					{
						temp2=cutMessage(s,start,mid);
					}
					else
					{
						temp2=s;
					}
						
					if(temp.equals("CARDID"))
					{
						returnMesg+="New Card No.->"+temp2+" ";
						b=1;
					}
					else
					{
						if(temp.equals("PHYSICALID"))
						{
							if(b==1)
							{
								returnMesg+=" | ";
							}
							else
							{
								b=1;
							}
							returnMesg+="Physical No. of New Card->"+temp2+" ";
							b=1;
						}
						else
						{
							if(temp.equals("TXM"))
							{
								if(b==1)
								{
									returnMesg+=" | ";
								}
								else
								{
									b=1;
								}
								returnMesg+="Barcode of New Card->"+temp2+" ";
							}
							else
							{
								if(temp.equals("LOSS"))
								{
									newstate=Integer.parseInt(temp2);
								
									if(b==1)
									{
										returnMesg+=" | ";
									}
									else
									{
										b=1;
									}

									if(newstate==0)
									{
										returnMesg+="Start Using(Lost)"+" ";
									}
									else
									{
										returnMesg+="Lost ";
									}
								}
								else
								{
									if(temp.equals("DAMAGE"))
									{
										newstate=Integer.parseInt(temp2);

										if(b==1)
										{
											returnMesg+=" | ";
										}
										else
										{
											b=1;
										}

										if(newstate==0)
										{
											returnMesg+="Start Using(Damage)"+" ";
										}
										else
										{
											returnMesg+="Damaged ";
										}
									}
									else
									{

										if(temp.equals("CANCEL"))
										{
											if(b==1)
											{
												returnMesg+=" | ";
											}
								
											returnMesg+="Cancellation ";
										}
									}
								}
							}
						}
					}

					if(mid==-1)
					{return returnMesg;
						
					}
					else
					{
						start=s.indexOf("\t");
						mid=s.length();
						s=cutMessage(s,start,mid);
						start=0;
						mid=s.indexOf("\t");
					}
				}
				return returnMesg;

			}
			else
			{
				if(temp.equals("new"))
				{
					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=0;
					mid=s.indexOf("\t");
					temp=cutMessage(s,start,mid);
					returnMesg="    Student No. "+temp+" Created\t=>    ";

					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=0;
					mid=s.indexOf("\t");
					temp=cutMessage(s,start,mid);
					returnMesg+="New Card's No.->"+temp;

					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=0;
					mid=s.indexOf("\t");
					temp=cutMessage(s,start,mid);
					returnMesg+=" | New Card's Physical No.->"+temp;

					start=mid;
					mid=s.length();
					s=cutMessage(s,start,mid);

					start=0;
					mid=s.indexOf("\t");
					temp=cutMessage(s,start,mid);
					returnMesg+=" | New Card's Barcode->"+temp;
				}
				else
				{
					if(temp.equals("delete"))
					{
						start=mid;
						mid=s.length();
						s=cutMessage(s,start,mid);

						returnMesg="    Student No. "+s+" Deleted";
					}
					else
					{
						if(temp.equals("From"))
						{
							returnMesg="\nDatabase ";

							start=mid;
							mid=s.length();
							s=cutMessage(s,start,mid);

							start=0;
							mid=s.indexOf("\t");
							temp=cutMessage(s,start,mid);

							returnMesg+=temp+" Updated.\nTime of Synchronism Message received: \t";

							start=mid;
							mid=s.length();
							s=cutMessage(s,start,mid);

							start=0;
							mid=s.indexOf("\t");
							temp=cutMessage(s,start,mid);

							returnMesg+=temp+"\nTime of synchronized: \t";

							start=mid;
							mid=s.length();
							s=cutMessage(s,start,mid);

							returnMesg+=s;
							
						}
						else
						{
							start=s.indexOf("\t");
							mid=s.lastIndexOf("\t");
							temp2=cutMessage(s,start,mid);

							returnMesg="\tDatabase "+temp2+"\tSynchronism No. "+temp+"\t";

							start=s.lastIndexOf("\t");
							mid=s.length();
							temp=cutMessage(s,start,mid);
							newstate=Integer.parseInt(temp);
							if(newstate==0)
							{
								returnMesg+="Waiting Synchronism's Confirm";
							}
							else
							{
								if(newstate==1)
								{
									returnMesg+="Synchronism Over";
								}
							}

						}
					}
				}
			}
		}
		return returnMesg;



	}

}