log.java

来自「《移动Agent技术》一书的所有章节源代码。」· Java 代码 · 共 527 行 · 第 1/2 页

				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
      return i;     	
	}
	//
	
	public int UpdateBZJ(int Num,int ID,String DateTime,int CoverageMoney){
		int i=0;
		
		PreparedStatement pstm;
		try{
		
	//	pstm=con.prepareStatement("Update AgentStatusInfo set AgentWorkStatus="+"'"+running+"'");	
			
	
		//	pstm=con.prepareStatement("Update AgentStatusInfo set HostName="+"'"+address+"'"+","+"AgentName="+"'"+classname+"'"+","+"AgentWorkStatus="+"'"+running+"'"+","+"AgentConnectionStatus="+"'"+ok+"'"+","+"WritingTime="+"'"+logtime+"'");
		    pstm=con.prepareStatement("Update QBCj127 set ID="+ID+","+"DateTime="+"'"+DateTime+"'"+","+"CoverageMoney="+CoverageMoney+"where Num="+Num);
			i=pstm.executeUpdate();  
      		
      }                   
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			while (ex != null){
				System.out.println("SQLState:"+ex.getSQLState());
				System.out.println("Message:"+ex.getMessage());	
				System.out.println("Vendor:"+ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
      return i;     	
	}
	//
	//end add for information
	//
	
		public int Update(long maxnum){
		int i=0;
	//	Date ndate = new Date();
	//	String logtime=ndate.toString();
		System.out.println("maxnum is: "+maxnum);
		PreparedStatement pstm;
		try{
		
	//	pstm=con.prepareStatement("Update AgentStatusInfo set AgentWorkStatus="+"'"+running+"'");	
			
	
		//	pstm=con.prepareStatement("Update AgentStatusInfo set HostName="+"'"+address+"'"+","+"AgentName="+"'"+classname+"'"+","+"AgentWorkStatus="+"'"+running+"'"+","+"AgentConnectionStatus="+"'"+ok+"'"+","+"WritingTime="+"'"+logtime+"'");
		pstm=con.prepareStatement("Update ZTB set maxnum="+maxnum);
			i=pstm.executeUpdate();  
      		
      }                   
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			while (ex != null){
				System.out.println("SQLState:"+ex.getSQLState());
				System.out.println("Message:"+ex.getMessage());	
				System.out.println("Vendor:"+ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
      return i;     	
	}
	//
	///delete records
	//
	
	
	public int bzjUpdate(long maxbzjnum){
		int i=0;
	//	Date ndate = new Date();
	//	String logtime=ndate.toString();
		System.out.println("maxbzjnum is: "+maxbzjnum);
		PreparedStatement pstm;
		try{
		
	//	pstm=con.prepareStatement("Update AgentStatusInfo set AgentWorkStatus="+"'"+running+"'");	
			
	
		//	pstm=con.prepareStatement("Update AgentStatusInfo set HostName="+"'"+address+"'"+","+"AgentName="+"'"+classname+"'"+","+"AgentWorkStatus="+"'"+running+"'"+","+"AgentConnectionStatus="+"'"+ok+"'"+","+"WritingTime="+"'"+logtime+"'");
		pstm=con.prepareStatement("Update ZTB set maxbzjnum="+maxbzjnum);
			i=pstm.executeUpdate();  
      		
      }                   
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			while (ex != null){
				System.out.println("SQLState:"+ex.getSQLState());
				System.out.println("Message:"+ex.getMessage());	
				System.out.println("Vendor:"+ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
      return i;     	
	}
	//
	public int Clear(String Del){
		int j=0;
		PreparedStatement pstm;
		try{
			pstm=con.prepareStatement(Del);
			j=pstm.executeUpdate(); 
			pstm.close();
			
			
		}
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			while (ex != null){
				System.out.println("SQLState:"+ex.getSQLState());
				System.out.println("Message:"+ex.getMessage());	
				System.out.println("Vendor:"+ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
      return j;
	}
	/////
	public int ClearAll(){
		int j=0;
		PreparedStatement pstm;
		try{
			pstm=con.prepareStatement("delete from log");
			j=pstm.executeUpdate(); 
			pstm.close();
			
			
		}
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			while (ex != null){
				System.out.println("SQLState:"+ex.getSQLState());
				System.out.println("Message:"+ex.getMessage());	
				System.out.println("Vendor:"+ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
      return j;
	}
   ///display records
   public String[][] Save(ResultSet rs) {
   	int i;
   	String tmpstr;
   	int recordNumber;
   	String[][] recordArray=null;
   	try{
   		ResultSetMetaData rsmd=rs.getMetaData();
   		int numCols=rsmd.getColumnCount();
   		int no=0;
   		recordNumber=300;
   		recordArray=new String[recordNumber][numCols];
   	
   	//display each column title
   		for(i=1;i<=numCols;i++){
   			recordArray[no][i-1]=rsmd.getColumnLabel(i);
   			
   			}
   		
   		while (rs.next()){				
				no++;
				for(i=1;i<=numCols;i++){
		
					tmpstr=rs.getString(i);
		
					if(rs.wasNull()){
		
						recordArray[no][i-1]="NULL";
		
					}
					else {
						recordArray[no][i-1]=tmpstr;
		
					}
				}
		
			}
		
		}
		catch(SQLException ex){
			System.out.println("\n***SQLException333 caught ***\n");
			while (ex != null){
				System.out.println("SQLState:"+ex.getSQLState());
				System.out.println("Message:"+ex.getMessage());	
				System.out.println("Vendor:"+ex.getErrorCode());
				ex=ex.getNextException();
				System.out.println("");
			}
		}
		
		return recordArray;			   	
	}
	
	public void display(String[][] recordArray){
		int l=recordArray.length;
		int ll=recordArray[1].length;
		System.out.println("array lenth is :"+l);
		System.out.println("record lenth is :"+ll);
		for (int i=0;i<l;i++){
			for (int j=0;j<ll;j++){
				if (recordArray[i][j]!=null)
					System.out.print(recordArray[i][j]+",");
		
				else return;
			}
			System.out.println(""); ///换行显示
	 	}
	 	

	}
		
	public void closeConnect(){
		try{
			con.close();
		}
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			System.out.println("SQLState:"+ex.getSQLState());
			System.out.println("Message:"+ex.getMessage());	
			System.out.println("Vendor:"+ex.getErrorCode());
      }            	
	}
	public void closeResult(){
		try{
			rs.close();
			stmt.close();
		
		}
		catch(SQLException ex){
			System.out.println("\n***SQLException caught ***\n");
			System.out.println("SQLState:"+ex.getSQLState());
			System.out.println("Message:"+ex.getMessage());	
			System.out.println("Vendor:"+ex.getErrorCode());
      }            	
	}
	
	public static void main(String args[])
	{
		log log=new log();
		log.Init("Ecmdb");
		
		log.Add("insert into log (type,describe,logtime) values ('aaaqq','bbbqqqq','cccqq')" );
		log.Add("err","aaaaaaaa");		
		
		log.ClearAll();
		log.Sql("select * from log");
	}
}