branchmiledao.java

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

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

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.BranchMile;

/**
 * @author dwr
 *
 */
public class BranchMileDAO {
   public static boolean checkPortName(String zlmc)	{
		
		boolean flag=false;
		DBConnect dbconn=new DBConnect();
		String sql = "select count(*) from zllcxxb where zlmc='"+zlmc.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 getUpPortName(String gkdm)	{
		
	    gkdm = gkdm.trim();
	    Map portMap = new HashMap();
	    String upportID="";
	    String upportname="";
		DBConnect dbconn=new DBConnect();
		String sql = "select gkdm,gkmc from lcxxb where lc=(select min(lc) from lcxxb where ";
		sql += "lc>(select lc from lcxxb where gkdm='"+ gkdm +"') ) ";	
		System.out.println(sql);
		try
		{
			ResultSet rs = dbconn.executeQuery(sql);
			if(rs.next()){
			upportID=rs.getString(1);
			upportname=rs.getString(2);}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
				System.out.println(sql);
			}
			dbconn.close();
			System.out.println(upportID);
			System.out.println(upportname);			
			portMap.put("upportID",upportID);
			portMap.put("upportname",upportname);
		return portMap;
	}
  
   public static BranchMile getBranchMile(String zldm)
	{
		zldm = zldm.trim();
	    BranchMile branchMile=new BranchMile();
		DBConnect dbconn=new DBConnect();		
		String sql = "select zlmc,sydm,sylc,xydm,xylc from zllcxxb ";
		sql += "WHERE ";
		sql += "zldm = '" + zldm+ "' ";			
		
		try
		{
			ResultSet rs = dbconn.executeQuery(sql);
			while(rs.next())
			{
				branchMile.setBranchmilename(rs.getString("zlmc"));
				branchMile.setUpportID(rs.getString("sydm"));
				branchMile.setUpmile(rs.getInt("sylc"));
				branchMile.setDownportID(rs.getString("xydm"));
				branchMile.setDownmile(rs.getInt("xylc"));
			}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			dbconn.close();
		return branchMile;
	}

	
public static boolean addBranchMile(String zlmc,String sydm,String sylc,String xydm,String xylc)
{
	int upmile=Integer.parseInt(sylc.trim());
    int downmile=Integer.parseInt(xylc.trim());
	boolean flag=false;
	String sqlselect1="select cast(isnull(max(zldm),'z0')as char) from zllcxxb where zldm like 'z%'";
	DBConnect dbconn1=new DBConnect();
	String id="";
	try{
		 ResultSet rs1=dbconn1.executeQuery(sqlselect1);
		 if(rs1.next())
		 id=rs1.getString(1);		 
		 }
		 catch (SQLException e) {
				e.printStackTrace();}
	dbconn1.close(); 
	int mileID=Integer.parseInt(id.substring(1).trim())+1;
	String zldm="z"+String.valueOf(mileID);
	System.out.println(zldm);
	
	DBConnect dbconn=new DBConnect();	
	String sqlinsert = "INSERT INTO zllcxxb(zldm,zlmc,sydm,sylc,xydm,xylc) VALUES( ";
	sqlinsert += "'" + zldm.trim() + "' ,";
	sqlinsert += " '" + zlmc.trim() + "' ,";
	sqlinsert += " '" + sydm.trim() + "' ,";
	sqlinsert += " " + upmile + " ,";
	sqlinsert += " '" + xydm.trim() + "' ,";
	sqlinsert += " " + downmile + " )";		
	System.out.println(sqlinsert);
	try
	{
		flag = dbconn.executeInsert(sqlinsert);
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
			System.out.println(sqlinsert);
		}
		dbconn.close();
	return flag;
}

public boolean deleteBranchMile(String zldm)
	{
	 String sql="delete zllcxxb where zldm='"+zldm.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 updateBranchMile(String zldm,String zlmc,String sydm,String sylc,String xydm,String xylc)
	{
	int upmile=Integer.parseInt(sylc.trim());
    int downmile=Integer.parseInt(xylc.trim());
	String sql="update zllcxxb set zlmc='"+zlmc.trim()+"',sydm='"+sydm.trim()+"',sylc="+upmile+",xydm='"+xydm.trim()+"',xylc="+downmile+" where zldm='"+zldm.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 zlmc="1156";
String sydm="1";
String sylc="1";
String xydm="1";
String xylc="1";
boolean flag;
flag=addBranchMile(zlmc,sydm,sylc,xydm,xylc);
System.out.println(flag);
}

}