mainmiledao.java

文件的上传和下载的实现,用JAva编写,非常简单

/** 
* Copyright 2007 Wuhan University of Technology. 
* All right reserved. 
* Create on 2007-3-22
*/ 

package edu.whut.cwts.maintain.action;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

import edu.whut.cwts.datasource.DBConnect;
import edu.whut.cwts.maintain.bean.MainMile;

/**
 * @author dwr
 *
 */
public class MainMileDAO {
	
	public static boolean checkPortName(String gkmc)	{
		
		boolean flag=false;
		DBConnect dbconn=new DBConnect();
		String sql = "select count(*) from lcxxb where gkmc='"+gkmc.trim()+"' ";		
		int count=0;
		try
		{
			ResultSet rs = dbconn.executeQuery(sql);
			if(rs.next())
			count=rs.getInt(1);
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
				System.out.println(sql);
			}
			 dbconn.close();
			if(count==0)
				flag=true;
		return flag;
	}
	   public Map getMiles(String gkdm)	{
			
		    Map mileMap = new HashMap();
		    String upmile="";
		    String downmile="";
			DBConnect dbconn=new DBConnect();
			DBConnect dbconn1=new DBConnect();
			String sql = "select lc from lcxxb where gkdm='"+ gkdm.trim() +"' ";
			String sql1 = "select min(lc) from lcxxb where lc>(select lc from lcxxb where gkdm='"+ gkdm.trim() +"') ";
			System.out.println(sql);
			try{
				 ResultSet rs1=dbconn1.executeQuery(sql1);
				 ResultSet rs=dbconn.executeQuery(sql);
				 if(rs1.next())
				 upmile=rs1.getString(1);
				 if(rs.next())
				 downmile=rs.getString(1);
				 }
				 catch (SQLException e) {
						e.printStackTrace();}
			dbconn1.close(); 
			dbconn.close(); 
			System.out.println("上游里程是："+upmile);
			System.out.println("下游里程是："+downmile);			
			mileMap.put("upmile",upmile);
			mileMap.put("downmile",downmile);
			return mileMap;
		}
	  
	public static MainMile getMainMile(String gkdm)
	{
		MainMile mainMile=new MainMile();
		DBConnect dbconn=new DBConnect();		
		String sql = "select gkmc,lc,fl from lcxxb ";
		sql += "WHERE ";
		sql += "gkdm = '" + gkdm.trim()+ "' ";			
		
		try
		{
			ResultSet rs = dbconn.executeQuery(sql);
			while(rs.next())
			{
				mainMile.setPortname(rs.getString("gkmc"));
				mainMile.setMile(rs.getInt("lc"));
				mainMile.setFeepoint(rs.getFloat("fl"));
			}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			 dbconn.close();			
		return mainMile;
	}

	
public static boolean addMainMile(String gkmc,String lc,String fl)
{
	int mile=Integer.parseInt(lc.trim());
	float feepoint=Float.parseFloat(fl.trim());
	boolean flag=false;
	DBConnect dbconn=new DBConnect();
	
	String sqlinsert = "INSERT INTO lcxxb(gkdm,gkmc,lc,fl) VALUES( ";
	sqlinsert += "' 1 ' ,";
	sqlinsert += " '" + gkmc.trim() + "' ,";
	sqlinsert += " " + mile + " ,";
	sqlinsert += " " + feepoint + ") "; 			
	
	try
	{
		flag = dbconn.executeInsert(sqlinsert);
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
			System.out.println(sqlinsert);
		}
		 dbconn.close();	
	return flag;
}

public boolean deleteMainMile(String gkdm)
	{
	 String sql="delete lcxxb where gkdm='"+gkdm.trim()+"'";
	 System.out.println(sql);
	 DBConnect dbconn2=new DBConnect();
	 boolean flag=false;
	 flag = dbconn2.executeDelete(sql);
	 //System.out.println(flag);
	 dbconn2.close();
	 return flag;
	
	}
   
public int updateMainMile(String gkdm,String gkmc,String lc,String fl)
	{
	int mile=Integer.parseInt(lc.trim());
	float feepoint=Float.parseFloat(fl.trim());
	String sql="update lcxxb set gkmc='"+gkmc.trim()+"',lc="+mile+",fl="+feepoint+" where gkdm='"+gkdm.trim()+"' ";
	 System.out.println(sql);
	 DBConnect dbconn = new DBConnect();
	 int flag=0;
	 try {
		flag = dbconn.executeUpdate(sql);
		
	 } catch (SQLException e) {
		// TODO 自动生成 catch 块
		e.printStackTrace();
	 }
	 //System.out.println(flag);
	 dbconn.close();
	 return flag;
	
	 }
public static void main(String[] args) {
	// TODO 自动生成方法存根
/*System.out.println("dd");
String gkmc="1156";
String lc="1";
String fl="1";
boolean flag;
flag=addMainMile(gkmc,lc,fl);
System.out.println(flag);*/
}

}