dvimportxml.java

基于struct结构的jsp

package com.ntsky.back;

import java.io.*;
import java.util.*;
import org.dom4j.*;
import org.dom4j.io.*;
import org.dom4j.dom.*;
import org.apache.log4j.Logger ;
import com.ntsky.xml.bbs.dto.AddressDTO;
import java.sql.*;
import com.ntsky.xml.bbs.AddressXML;
import com.ntsky.xml.bbs.XMLCreator;
/**
 * <p>Title: Ntsky OpenSource BBS</p>
 * <p>Description: 从动网将ip信息导入到xml(初始情况使用的类)</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: WWW.FM880.COM</p>
 * @author 姚君林
 * @version 1.0
 */

public class DVImportXML {
    private final static Logger logger = Logger.getLogger(DVImportXML.class);
    private static DVImportXML dvImportXML = null;
    private static Object obj = new Object();
    private DVImportXML(){}

    public static DVImportXML getInstance(){
        if (dvImportXML == null) {
            synchronized(obj){
                if (dvImportXML == null) {
                    dvImportXML = new DVImportXML();
                    logger.info("创建XML处理者对象 : " + dvImportXML);
                }
            }
        }
        return dvImportXML;
    }
    /**
     * 获取access的数据库连接
     */
    public Connection getAccessConnection() throws SQLException{
        Connection conn = null;
        try {
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); //载入驱动程序类别
            conn = DriverManager.getConnection("jdbc:odbc:dvbbs");
        }
        catch (ClassNotFoundException ex) {
        }
        return conn;
    }
    /**
     * 从dvbbs6中导出数据
     */
    public Iterator getIpInfo() {
        ArrayList al = new ArrayList();
        try {
            Connection conn = getAccessConnection();
            Statement stmt = conn.createStatement(); //建立Statement对象
            ResultSet rs = stmt.executeQuery("select * from address");
            while(rs.next()){
                AddressDTO addressDTO = new AddressDTO();
                addressDTO.setAddrIp1(rs.getString("ip1"));
                addressDTO.setAddrIp2(rs.getString("ip2"));
                addressDTO.setAddrCountry(rs.getString("country"));
                addressDTO.setAddrCity(rs.getString("city"));
                al.add(addressDTO);
            }
        }
        catch (Exception ex) {
            System.out.println("获取DV数据错误 : " + ex.getMessage());
        }
        return al.iterator();
    }
    /**
     * 获取数据测试
     * @return String
     */
    public String getInfo(){
       try {
           Connection conn = getAccessConnection();
           Statement stmt = conn.createStatement(); //建立Statement对象
           ResultSet rs = stmt.executeQuery("select * from address");
           rs.next();
           return rs.getString(1);
       }
       catch (Exception ex) {
           logger.info("获得数据发生问题 : " + ex.getMessage());
       }
       return null;
    }
    public static void main(String[] args) {
        DVImportXML dv = DVImportXML.getInstance();
        //System.out.println("DVImportXML.getInstance().getInfo() = "+ dv.getInfo());
        Iterator iter =  dv.getIpInfo();
        AddressXML addressXML = XMLCreator.getInstance().getAddressXML();
        addressXML.ImportDVToXML(iter);
        /*while (iter.hasNext()) {
            AddressDTO item = (AddressDTO)iter.next();
            System.out.println("item = " + item.getAddrIp1()+item.getAddrIp2()+item.getAddrCountry()+item.getAddrCity());
        }*/
    }
}