goalrevenuedao.java

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

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

package edu.whut.cwts.maintain.action;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

import edu.whut.cwts.datasource.DBConnect;
/**
 * @author dwr
 *
 */
public class GoalRevenueDAO {
	
	/*public String departmentzddmCal(String level,String zddm){
		String sqlselect="";
		String newzddm="";
		if(level.trim().equals("1")){
			sqlselect="select cast(isnull(max(zddm),'100000') as int)+10000  from zdxxb where zddm like '1%0000' and zddm<>'100000'  ";
		   // System.out.println(sqlselect);	
		    //System.out.println("cccccccccccc");
		}
		else if(level.trim().equals("2")){
			sqlselect="select cast(isnull(max(zddm),'200000') as int)+10000 from zdxxb where zddm like '2%0000' and zddm<>'100000'  ";
			
		}
        else if(level.trim().equals("3")){
        	String center=zddm.substring(0,2);
        	sqlselect="select cast(isnull(max(zddm),'"+center+"0000') as int)+100 from zdxxb where zddm like '"+center+"%00' and zddm<>'"+center+"0000' ";
		}
        else if(level.trim().equals("4")){
			String station="";
			try {
				station = this.getZddm(zddm).substring(0,4);
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			sqlselect="select cast(isnull(max(zddm),'"+station+"00') as int)+1 from zdxxb where zddm like '"+station+"%' and zddm<>'"+station+"00' ";
		}
        else if(level.trim().equals("5")){
			String center2=zddm.substring(0,2);
			sqlselect="select cast(isnull(max(zddm),'"+center2+"0000') as int)+1 from zdxxb where zddm like '"+center2+"00%' and zddm<>'"+center2+"0000'";
		}
		DBConnect dbconn=new DBConnect();
		
		ResultSet rs;
		try {
			rs=dbconn.executeQuery(sqlselect);
			while (rs.next()){
				newzddm=rs.getString(1);
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		
		
			
		
		
		return newzddm;
		
	}
public ArrayList getZjz(String zddm) throws SQLException{
		
		String center=zddm.substring(0,2);
		
		String sql="select zdmc from zdxxb where (zddm like '"+center+"%00' or zddm like '"+center+"00%') and zddm<>'"+center+"0000' ";
				 
		 DBConnect dbconn=new DBConnect();
		 			
		 ResultSet rs=dbconn.executeQuery(sql);
		//System.out.println("test");
		ArrayList zjz=new ArrayList();
		while (rs.next()){
			zjz.add(rs.getString("zdmc"));
		}
		return zjz;
	
		
	}
	
	public ArrayList getZjd(String zdmc) throws SQLException{
		String sqlzjd="";
		String sqlzddm="select zddm from zdxxb where zdmc='"+zdmc.trim()+"'";
		System.out.println(sqlzddm);
		 DBConnect dbconn=new DBConnect();
		 ArrayList zjd=new ArrayList();	
		 ResultSet rs=dbconn.executeQuery(sqlzddm);
		 while (rs.next()){
				String zddm=rs.getString("zddm");
				String zjdzm=zddm.substring(0,4);
				sqlzjd="select *from zdxxb where zddm like '"+zjdzm+"%' and zddm<>"+zddm+"";
				System.out.println(sqlzjd);
				DBConnect dbconn2=new DBConnect();
					
				ResultSet rs2=dbconn2.executeQuery(sqlzjd);
				System.out.println("test");
				
				while (rs2.next()){
					zjd.add(rs2.getString("zdmc"));
				}
				System.out.println(zjdzm);
				
			}
		 return zjd;
	}
	public String getZdmc(String zddm) throws SQLException{
		String sql="select zdmc from zdxxb where zddm='"+zddm+"'";
		DBConnect dbconn2=new DBConnect();
		String zdmc="";
		ResultSet rs2=dbconn2.executeQuery(sql);
		System.out.println("test");
		
		while (rs2.next()){
			zdmc=rs2.getString("zdmc");
		}
		return zdmc;
	}
	public String getZddm(String zdmc) throws SQLException{
		String sql="select zddm from zdxxb where zdmc='"+zdmc+"'";
		DBConnect dbconn2=new DBConnect();
		String zddm="";
		ResultSet rs2=dbconn2.executeQuery(sql);
		System.out.println("test");
		
		while (rs2.next()){
			zddm=rs2.getString("zddm");
		}
		return zddm;
	}*/
public ArrayList selectYears(String zddm) throws SQLException{
	    ArrayList years=new ArrayList();
	    years.add("请选择......");
		String sql="select nf from hyfmbsr where zddm='"+zddm.trim()+"' ";				 
		DBConnect dbconn=new DBConnect();
		try
		{
		ResultSet rs=dbconn.executeQuery(sql);
		//System.out.println("test");			
		while (rs.next()){
			years.add(rs.getString("nf"));
		}
		} 
		catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		 dbconn.close();
		return years;	
		
	}
    public static float getGoalRevenue(String zddm,String nf)
	{
    	float goalrevenue = 0;
		DBConnect dbconn=new DBConnect();		
		String sql = "select mbsr from hyfmbsr ";
		sql += "WHERE ";
		sql += "zddm = '" + zddm.trim() + "' and nf = '" + nf.trim() + "'";			
		
		try
		{
			ResultSet rs = dbconn.executeQuery(sql);
			while(rs.next())
			{
				goalrevenue=rs.getFloat("mbsr");
			}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			 dbconn.close();			
		return goalrevenue;
	}

	
public static boolean addGoalRevenue(String zddm,String nf,String mbsr)
{
	boolean flag=false;
	float goalrevenue=Float.parseFloat(mbsr.trim());
	DBConnect dbconn=new DBConnect();
	
	String sqlinsert = "INSERT INTO hyfmbsr(nf,zddm,mbsr) VALUES( ";
	
	sqlinsert += " '" + nf.trim() + "' ,";
	sqlinsert += " '" + zddm.trim() + "' ,";
	sqlinsert += " " + goalrevenue + ") "; 			
	
	try
	{
		flag = dbconn.executeInsert(sqlinsert);
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
			System.out.println(sqlinsert);
		}
		 dbconn.close();	
	return flag;
}

public boolean deleteGoalRevenue(String zddm,String nf)
	{
	 String sql="delete hyfmbsr where zddm='"+zddm.trim()+"' and nf='"+nf.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 updateGoalRevenue(String zddm,String nf,String mbsr)
	{
	 float goalrevenue=Float.parseFloat(mbsr.trim());
	 String sql="update hyfmbsr set mbsr="+goalrevenue+" where zddm='"+zddm.trim()+"' and nf='"+nf.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 zddm="100000";
String nf="2007";
String mbsr="1256";
boolean flag;
flag=addGoalRevenue(zddm,nf,mbsr);
System.out.println(flag);
}

}