bosql.java.svn-base

一套DB2 7到8版本的程序。内附创建ZIP的JAVA类

package com.highsoft.bo;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Properties;

import com.highsoft.dao.Dao;
import com.highsoft.database.DB7Manager;

public class BoSql {
	private Dao d=new Dao();
	public void Insert(String tablename,String tablerow,List result,String Xmlrow)
	{
		
		HashMap map=new HashMap();
		//List insertlist=new ArrayList();
		String []newxmlrow=Xmlrow.split(",");
		for (int i = 0; i < result.size(); i++) {
			StringBuffer sb=new StringBuffer();
			sb.append("insert into "+tablename+"");
			map=(HashMap) result.get(i);
			sb.append("("+tablerow+") values(");
			for (int j = 0; j < newxmlrow.length; j++) {
				//System.out.println(newxmlrow[j]);
				
				if(tablename.equals("DB2ADMIN.T_SYSCODE")||tablename=="DB2ADMIN.T_SYSCODE")
				{
					if(j==4)
					{
						sb.append(""+map.get(newxmlrow[j])+",");
					}else
					{
						sb.append("'"+map.get(newxmlrow[j])+"',");
					}
					//System.out.println(map.get(newxmlrow[j]));
				}else if(tablename.equals("DB2ADMIN.T_AREA")||tablename=="DB2ADMIN.T_AREA")
				{
					//System.out.println(j);
					//System.out.println(map.get(newxmlrow[j]));
					if(j==5||j==6||j==7||j==8||j==10||map.get(newxmlrow[5]).equals("")||map.get(newxmlrow[5])==null||map.get(newxmlrow[6]).equals("")||map.get(newxmlrow[6])==null||map.get(newxmlrow[7]).equals("")||map.get(newxmlrow[7])==null||map.get(newxmlrow[8]).equals("")||map.get(newxmlrow[8])==null||map.get(newxmlrow[10]).equals("")||map.get(newxmlrow[10])==null)
					{
						sb.append(""+map.get(newxmlrow[j])+",");
					}else
					{
						sb.append("'"+map.get(newxmlrow[j])+"',");
					}
				}else if(map.get(newxmlrow[j]).equals("null")||map.get(newxmlrow[j])=="null")
				{
					sb.append("'',");
				}else{
					sb.append("'"+map.get(newxmlrow[j])+"',");
				}
			}
			sb.append(")");
			sb.deleteCharAt(sb.length()-2);
			//System.out.println(sb.toString()+"\n");
			
			boolean flag=d.Insert8(sb.toString());
			//System.out.println(flag);
			if(!flag)
			{
				System.out.println(sb.toString()+"\n");
			}
		}
		//d.close();
		System.out.println(tablename+"表导入成功");
	}

	public String select(String tablename,String tablerow)
	{
		String sql="select "+tablerow+" from "+tablename+"";
		return sql;
	}
	
	public String del(String tablename)
	{
		Properties pro=new Properties();
		String sql="";
		try {
			pro.load(DB7Manager.class.getResourceAsStream("jhsy.properties"));
			sql="import from "+pro.getProperty("dist.null")+" of del replace into "+tablename+"";
		} catch (IOException e) {
			// TODO Auto-generated catch block
			System.out.println(e.getMessage());
			return null;
		}
		return sql;
	}
}