companydao.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.Company;

/**
 * @author dwr
 *
 */
public class CompanyDAO {
	
	public static Map checkCompanyInfo(String selectCompany,String company1,String gslx)
    {
		selectCompany = selectCompany.trim();
		gslx=gslx.trim();
		String companyinfo=company1.trim();
	    Map companymap = new HashMap();
	    Company company = new Company();
	    String count="";
	    String sql="";
	    String sql1="";
	    if(selectCompany.trim().equals("1")){
		   sql="select gsdm from gsxxb where gsdm='"+companyinfo+"' and gslx='"+ gslx +"'";
		   sql1="select count(*) from gsxxb where gsdm='"+companyinfo+"' and gslx='"+ gslx +"'";
	    }
	    else if(selectCompany.trim().equals("2")){
		   sql="select gsdm from gsxxb where gsmc='"+companyinfo+"' and gslx='"+ gslx +"'";
		   sql1="select count(*) from gsxxb where gsmc='"+companyinfo+"' and gslx='"+ gslx +"'";
	    }
	    System.out.println(sql);
	    System.out.println(sql1);
	    DBConnect dbconn1=new DBConnect();
	    try
		   {
			ResultSet rs1 = dbconn1.executeQuery(sql1);
			if(rs1.next()){
			count=String.valueOf(rs1.getInt(1));
			companymap.put("count",count);}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			 dbconn1.close();
	    DBConnect dbconn=new DBConnect();
	    try
	    {
		 ResultSet rs = dbconn.executeQuery(sql);
		 while(rs.next())
		 {			
			company.setCompanyID(rs.getString("gsdm"));
			companymap.put("company",company);
		 }
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		 dbconn.close();			
	return companymap;
   }
	
	public String checkCompanyName(String gsmc)
    {
	    String count="";
	    String sql ="select count(*) from gsxxb where gsmc='"+gsmc.trim()+"'";
	    System.out.println(sql);
	    DBConnect dbconn=new DBConnect();
	    try
	    {
		 ResultSet rs = dbconn.executeQuery(sql);
		 if(rs.next())
		 count=String.valueOf(rs.getInt(1));
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		 dbconn.close();			
	return count;
   }
	
	public static Company getCompany(String gsmc)
    {
	Company company=new Company();
	DBConnect dbconn=new DBConnect();		
	String sql = "select * from gsxxb ";
	sql += "WHERE ";
	sql += "gsmc = '" + gsmc.trim()+ "'";			
	System.out.println(sql);
	try
	{
		ResultSet rs = dbconn.executeQuery(sql);
		while(rs.next())
		{
			company.setCompanyID(rs.getString("gsdm"));
			company.setCompanyname(rs.getString("gsmc"));
			company.setContactperson(rs.getString("lxr"));	
			company.setContactphone(rs.getString("lxdh"));
			company.setCompanytype(rs.getString("gslx"));
		}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		 dbconn.close();		
	return company;
   }


public static boolean addCompany(String gsmc,String lxr,String lxdh,String gslx)
{
boolean flag=false;
DBConnect dbconn=new DBConnect();

String sqlinsert = "INSERT INTO gsxxb(gsdm,gsmc,lxr,lxdh,gslx)";
sqlinsert +="VALUES( ";
sqlinsert += "' 1' ,";
sqlinsert += " '" + gsmc.trim() + "' ,";
sqlinsert += " '" + lxr.trim() + "' ,";
sqlinsert += " '" + lxdh.trim() + "' ,";
sqlinsert += " '" + gslx.trim() + "') "; 			
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 deleteCompany(String gsdm)
{
 String sql="delete gsxxb where gsdm='"+gsdm.trim()+"'";
 System.out.println(sql);
 DBConnect dbconn2=new DBConnect();
 boolean flag=false;
 flag = dbconn2.executeDelete(sql);
 dbconn2.close();
 //System.out.println(flag);
 return flag;

}

public static int updateCompany(String gsdm,String gsmc,String lxr,String lxdh,String gslx)
{
 String sql="update gsxxb set gsmc='"+gsmc.trim()+"',lxr='"+lxr.trim()+"',lxdh='"+lxdh.trim()+"',gslx='"+gslx.trim()+"'";
 sql += "where gsdm='"+gsdm.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("dd11111111");
String gsdm="1";
String gsmc="2";
String lxr="2";
String lxdh="2";
String gslx="2";
int flag;
System.out.println("dd11");
flag=updateCompany(gsdm,gsmc,lxr,lxdh,gslx);
System.out.println(flag);
Map commap=new HashMap();
commap=checkCompanyInfo("1","12","1");
String count=(String) commap.get("count");
System.out.println(count);
}

}