converter.cs

可以实现任意数据库之间的数据互导,可以实现任意数据库之间的数据互导

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Collections;
using LC_XMLControl;

namespace AccessToXml
{
    public class Converter : IThransProtocol
    {
        #region IThransProtocol 成员

        public void closeDesConnection()
        {
            
        }

        public void closeSourceConnection()
        {
            //_sourceconnection.Close();
        }

        public void createDesContentction(string constr)
        {
           
        }

        public void createSourceContenction(string constr)
        {
            try
            {
                string cstr = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + constr;
                _sourceconnection = new OleDbConnection(cstr);
                _sourceconnection.Open();
            }
            catch (Exception ee)
            {
                MessageBox.Show(ee.Message.ToString());
            }
        }

        private int _cursum;
        public int cursum
        {
            get
            {
                return _cursum;
            }
            set
            {
                _cursum = value;
            }
        }

        private XmlManager _desconnection;
        public object desconnection
        {
            get
            {
                return _desconnection;
            }
            set
            {
                value = (XmlManager)_desconnection;
            }
        }
        private int _dtype;
        public int dtype
        {
            get
            {
                return _dtype;
            }
            set
            {
                _dtype = value;
            }
        }

        public ArrayList getAllDesField(string table)
        {
            return null;
        }

        public ArrayList getAllDesTable()
        {
            return null;
        }

        public ArrayList getAllSourceField(string table)
        {
            ArrayList altemp = new ArrayList();
            DataTable dt = new DataTable();
            dt = _sourceconnection.GetOleDbSchemaTable(OleDbSchemaGuid.Columns, new Object[] { null, null, table, null });
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                altemp.Add(dt.Rows[i].ItemArray[3].ToString());
            }
            return altemp;

        }

        public ArrayList getAllSourceTable()
        {
            ArrayList altemp = new ArrayList();
            DataTable dt = new DataTable();
            dt = _sourceconnection.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new Object[] { null, null, null, "TABLE" });
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                altemp.Add(dt.Rows[i].ItemArray[2].ToString());
            }
            return altemp;

        }
        private string _info;
        public string info
        {
            get
            {
                return _info;
            }
            set
            {
                _info = value;
            }
        }

        public ArrayList msg
        {
            get
            {
                return msg;
            }
            set
            {
                msg = (ArrayList)msg;
            }
        }

        public DataTable sourceToXml(string source, ArrayList allfield)
        {
            string temp = "";
            for (int i = 0; i < allfield.Count; i++)
            {
                temp += allfield[i].ToString() + ",";
            }
            temp = temp.Substring(0, temp.Length - 1);
            OleDbCommand cmd = new OleDbCommand("select " + temp + " from " + source);
            cmd.Connection = _sourceconnection;
            DataTable dt = new DataTable();
            OleDbDataAdapter sda = new OleDbDataAdapter(cmd);
            sda.Fill(dt);
            return dt;

        }

        private OleDbConnection _sourceconnection;
        public object sourceconnection
        {
            get
            {
                return _sourceconnection;
            }
            set
            {
                _sourceconnection = (OleDbConnection)value;
            }
        }

        private string _spliter;
        public string spliter
        {
            get
            {
                return _spliter;
            }
            set
            {
                _spliter = value; ;
            }
        }

        private int _stype;
        public int stype
        {
            get
            {
                return _stype;
            }
            set
            {
                _stype = value;
            }
        }

        public void xmlToDes(string des, ArrayList rows, ArrayList fields)
        {
            
        }

        #endregion

        #region IThransProtocol 成员
        private ArrayList _allres;
        public ArrayList allres
        {
            get
            {
                return _allres;
            }
            set
            {
                _allres = (ArrayList)value;
            }
        }
        private ArrayList _errorres;
        public ArrayList errorres
        {
            get
            {
                return _errorres;
            }
            set
            {
                _errorres = (ArrayList)value;
            }
        }

        #endregion
    }
}