referencepricedao.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;
import edu.whut.cwts.maintain.bean.ReferencePrice;
/**
 * @author dwr
 *
 */
public class ReferencePriceDAO {
	
	public ArrayList getArrivePorts(String qsg) throws SQLException{
		
		String sql="select ddg from hyzdj where qsg='"+qsg.trim()+"' ";				 
		DBConnect dbconn=new DBConnect();		 			
		ResultSet rs=dbconn.executeQuery(sql);
		//System.out.println("test");
		ArrayList arriveports=new ArrayList();
		arriveports.add("请选择......");
		while (rs.next()){
			arriveports.add(rs.getString("ddg"));
		}
		 dbconn.close();
		return arriveports;	
		
	}
	
    public ArrayList getGk() throws SQLException{
		
		String sql="select gkmc from lcxxb ";				 
		DBConnect dbconn=new DBConnect();		 			
		ResultSet rs=dbconn.executeQuery(sql);
		//System.out.println("test");
		ArrayList ports=new ArrayList();
		ports.add("请选择......");
		while (rs.next()){
			ports.add(rs.getString("gkmc"));
		}
		 dbconn.close();
		return ports;			
	}

	public static ReferencePrice getReferencePrice(String qsg,String ddg)
	{
		DBConnect dbconn=new DBConnect();	
		ReferencePrice referencePrice = new ReferencePrice();
		String sql = "select * from hyzdj ";
		sql += "WHERE ";
		sql += "qsg = '" + qsg.trim() + "' and ";
        sql += "ddg = '" + ddg.trim() + "' ";			
		
		try
		{
			ResultSet rs = dbconn.executeQuery(sql);
			while(rs.next())
			{
				referencePrice.setMile(rs.getInt("lc"));
				referencePrice.setLevel1(rs.getFloat("jb1"));
				referencePrice.setLevel2(rs.getFloat("jb2"));
				referencePrice.setLevel3(rs.getFloat("jb3"));
				referencePrice.setLevel4(rs.getFloat("jb4"));
				referencePrice.setLevel5(rs.getFloat("jb5"));
				referencePrice.setLevel6(rs.getFloat("jb6"));
				referencePrice.setLevel7(rs.getFloat("jb7"));
				referencePrice.setLevel8(rs.getFloat("jb8"));
				referencePrice.setLevel9(rs.getFloat("jb9"));
				referencePrice.setLevel10(rs.getFloat("jb10"));
			}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			 dbconn.close();			
		return referencePrice;
	}

	
public static boolean addReferencePrice(String qsg,String ddg,String lc,String jb1,String jb2,String jb3,String jb4,String jb5,String jb6,String jb7,String jb8,String jb9,String jb10)
{
   	int _lc = Integer.parseInt(lc.trim());
   	float _jb1 = Float.parseFloat(jb1.trim());
   	float _jb2 = Float.parseFloat(jb2.trim());
   	float _jb3 = Float.parseFloat(jb3.trim());
   	float _jb4 = Float.parseFloat(jb4.trim());
   	float _jb5 = Float.parseFloat(jb5.trim());
   	float _jb6 = Float.parseFloat(jb6.trim());
   	float _jb7 = Float.parseFloat(jb7.trim());
   	float _jb8 = Float.parseFloat(jb8.trim());
   	float _jb9 = Float.parseFloat(jb9.trim());
   	float _jb10 = Float.parseFloat(jb10.trim());
	boolean flag=false;
	DBConnect dbconn=new DBConnect();	
	String sqlinsert = "INSERT INTO hyzdj(qsg,ddg,lc,jb1,jb2,jb3,jb4,jb5,jb6,jb7,jb8,jb9,jb10) VALUES( ";
	sqlinsert += " '" + qsg.trim() + "' ,";
	sqlinsert += " '" + ddg.trim() + "' ,";
	sqlinsert += " " + _lc + " ,";	
	sqlinsert += " " + _jb1 + " ,";
	sqlinsert += " " + _jb2 + " ,";
	sqlinsert += " " + _jb3 + " ,";
	sqlinsert += " " + _jb4 + " ,";
	sqlinsert += " " + _jb5 + " ,";
	sqlinsert += " " + _jb6 + " ,";
	sqlinsert += " " + _jb7 + " ,";
	sqlinsert += " " + _jb8 + " ,";
	sqlinsert += " " + _jb9 + " ,";
	sqlinsert += " " + _jb10 + " )";
	
	try
	{
		flag = dbconn.executeInsert(sqlinsert);
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
			System.out.println(sqlinsert);
		}
		 dbconn.close();	
	return flag;
}

public boolean deleteReferencePrice(String qsg,String ddg)
	{
     String sql="delete hyzdj where qsg='"+qsg.trim()+"' and ddg='"+ddg.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 updateReferencePrice(String qsg,String ddg,String lc,String jb1,String jb2,String jb3,String jb4,String jb5,String jb6,String jb7,String jb8,String jb9,String jb10)
	{
	 int _lc = Integer.parseInt(lc.trim());
   	 float _jb1 = Float.parseFloat(jb1.trim());
   	 float _jb2 = Float.parseFloat(jb2.trim());
   	 float _jb3 = Float.parseFloat(jb3.trim());
   	 float _jb4 = Float.parseFloat(jb4.trim());
   	 float _jb5 = Float.parseFloat(jb5.trim());
   	 float _jb6 = Float.parseFloat(jb6.trim());
   	 float _jb7 = Float.parseFloat(jb7.trim());
   	 float _jb8 = Float.parseFloat(jb8.trim());
   	 float _jb9 = Float.parseFloat(jb9.trim());
   	 float _jb10 = Float.parseFloat(jb10.trim());
	 String sql="update hyzdj set ";
	 sql += "lc= " + _lc + " ,";	
	 sql += "jb1= " + _jb1 + " ,";
	 sql += "jb2= " + _jb2 + " ,";
	 sql += "jb3= " + _jb3 + " ,";
	 sql += "jb4= " + _jb4 + " ,";
	 sql += "jb5= " + _jb5 + " ,";
	 sql += "jb6= " + _jb6 + " ,";
	 sql += "jb7= " + _jb7 + " ,";
	 sql += "jb8=" + _jb8 + " ,";
	 sql += "jb9= " + _jb9 + " ,";
	 sql += "jb10=" + _jb10 + "  ";
	 sql += "where qsg='"+qsg.trim()+"' and ddg='"+ddg.trim()+"'";
	 System.out.println(sql);
	 DBConnect dbconn = new DBConnect();
	 int flag=0;
	 try {
		flag = dbconn.executeUpdate(sql);
		
	 } catch (SQLException e) {
		// TODO 自动生成 catch 块
		e.printStackTrace();
	 }
	 dbconn.close();
	 //System.out.println(flag);
	 return flag;
	
	 }
public static void main(String[] args) {
	// TODO 自动生成方法存根
System.out.println("dd");
boolean flag;
flag=addReferencePrice("1","2","2","2","2","2","2","2","2","2","2","2","2");
System.out.println(flag);
}

}