xmltodb.java

用java开发的QQ管理系统

package com.zlf.createdb;

/**
 * XMLtoDB
 * @author zlf
 */

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.text.ParseException;
import java.util.Date;
import java.util.HashMap;
import java.util.Vector;

import com.zlf.dao.DBUtil;
import com.zlf.dao.DaoFactory;
import com.zlf.dao.DeptDao;
import com.zlf.dao.DeptDaoOracleImp;
import com.zlf.dao.UserDao;
import com.zlf.dao.UserDaoOracleImp;
import com.zlf.dao.vo.Dept;
import com.zlf.dao.vo.User;

public class XMLtoDB {
	
	
	private HashMap hashMap = new HashMap();
	private HashMap hashMap2 = new HashMap();
	private Vector data = null;
	private UserDao userDao = DaoFactory.newInstance().createUserDao("xml");
	private DeptDao deptDao = DaoFactory.newInstance().createDeptDao("xml");
	
	/**
	 * 
	 * @return
	 * 
	 * 返回所有用户
	 */
	public Vector getUserVector(){
		
		//返回所有用户
		hashMap.put("8", "");
		data =userDao.selectUser(hashMap);
		hashMap.clear();
		return data;
		
		
	}
	
	/**
	 * 
	 * @return
	 * 
	 * 返回所有部门
	 */
	public Vector getDeptVector(){
		
		//返回所有部门
		hashMap2.put("1", "");
		data =deptDao.selectDept(hashMap2);
		hashMap2.clear();
		return data;
		
		
	}
	
	
	
	

	/**
	 * 
	 * 删除数据库中所有用户
	 * @return int 
	 *  1成功
	 *  0失败
	 *  
	 */
	public int deleteAllUser() {
//		System.out.println("get con begin");
		Connection conn = DBUtil.getConnection();
//		System.out.println("get con end");
		PreparedStatement pStatm = null;
		try {
			pStatm = conn
					.prepareStatement("delete from t_user");
			pStatm.executeUpdate();
			
//			System.out.println("delete all user ok");
			
			return 1;

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
//			System.out.println("delete all user  no ok");
			
			return 0;
		} finally {
			DBUtil.close(pStatm);
			DBUtil.close(conn);
		}
	}
	
	
	/**
	 * 
	 * 删除数据库中所有部门
	 * @return int 
	 *  1成功
	 *  0失败
	 *  
	 */
	public int deleteAllDept() {
		Connection conn = DBUtil.getConnection();
		PreparedStatement pStatm = null;

		try {
			pStatm = conn
					.prepareStatement("delete from t_dept");
			pStatm.executeUpdate();
//			System.out.println("delete all dept ok");
			return 1;

		} catch (SQLException e) {
			e.printStackTrace();
//			System.out.println("delete all dept  no  ok");
			return 0;
		} finally {
			DBUtil.close(pStatm);
			DBUtil.close(conn);
		}

	}
	
	public void toDB(){
		
		
		
		XMLtoDB d = new XMLtoDB();
		

		Vector uservector = d.getUserVector();
		

		
		Vector v = null;
		if (uservector == null) return;

		
		deleteAllUser();

		deleteAllDept();

		
		Vector deptvector = d.getDeptVector();
		
		for (int i = 0; i < deptvector.size(); i++){
			Dept dept = new Dept();
			v =(Vector) deptvector.get(i);
			Object [] sary = v.toArray();
			dept.setDeptId(sary[0].toString());
			dept.setDeptName(sary[1].toString());
			dept.setDeptRemark(sary[2].toString());
			DeptDaoOracleImp deptdaoimp = new DeptDaoOracleImp();
			
			deptdaoimp.addDept(dept);
//			System.out.println("add dept ok");
		}
		
		
		for (int index = 0; index < uservector.size();index++){
			
			User user = new User();
			v = (Vector) uservector.get(index);
			Object [] sary = v.toArray();
//			System.out.println(sary[0]);
//			System.out.println(sary[1]);
//			System.out.println(sary[2]);
//			System.out.println(sary[3]);
//			System.out.println(sary[4]);
//			System.out.println(sary[5]);
//			System.out.println(sary[6]);
//			System.out.println(sary[7]);
//			System.out.println("8888888"+sary[8]);
//			System.out.println("99999999"+sary[9]);
//			System.out.println("10000000"+sary[10]);
//			System.out.println("11111111"+sary[11]);
//			System.out.println(sary[12]);
//			System.out.println(sary[13]);



			user.setUserId(sary[0].toString());
			user.setUserPwd(sary[1].toString());
			user.setUserName(sary[2].toString());
			user.setUserNickName(sary[3].toString());
			user.setUserSex(sary[4].toString());
			user.setUserIcon(sary[5].toString());
			user.setUserAge(Integer.parseInt(sary[6].toString()));
			user.setDeptId(sary[7].toString());
			user.setUserPhone(sary[8].toString());
			user.setUserAddr(sary[10].toString());
			
		
			//System.out.println(sary[10].toString());
			
			java.text.SimpleDateFormat   format   =new   java.text.SimpleDateFormat("yyyy-MM-dd hh:mm:ss");   
			Date  date = null;  
			try {
				date = format.parse(sary[9].toString());
			} catch (ParseException e) {
				e.printStackTrace();
			}

		
			user.setUserLastLogin(date);
			
			
			
			

			
			try {
				date = format.parse(sary[11].toString());
			} catch (ParseException e) {
				e.printStackTrace();
			}

		
			user.setUserRegDate(date);
			
			

			
			user.setUserLoginNum(Integer.parseInt(sary[12].toString()));
			user.setUserOnline(Integer.parseInt(sary[13].toString()));
			
			UserDaoOracleImp userdaoimp = new UserDaoOracleImp();
			
			if (userdaoimp.addUser(user) > 0 ){
				System.out.println("add user ok");
				
			}
			

		}		
	}
	
	
	
	
	


}