qclasspoint.cs

多线程导入数据,代进度条,本程序是.net语言编写,可以参考其中的例子

using System;
using System.Collections.Generic;
using System.Text;
using System.jdTools;
using System.Data;
using System.Data.SqlClient;
using Transition.Config;

namespace Transition.qClassPoint
{
    public class TransitionqClassPoint
    {
        public static int GetOldTotalCount()
        {
            myDataBase db = oldDataBase.getDataBase();
            string sql = "select count(*) from exam_point where deleted=0";
            return db.GetFirstInt(sql);
        }
        private static SqlDataReader GetOldDataReader(int start,int count)
        {
            myDataBase odb = oldDataBase.getDataBase();
            string from = string.Format("from OPENDATASOURCE('SQLOLEDB','Data Source={0};User ID={1};Password={2}').{3}.dbo.exam_point", odb.Host, odb.UserID, odb.Pwd, odb.Name);
            from += " inner join jd_qClass on jd_qClassOID=classid";
            string where = "where deleted=0";
            string order = "order by pointid";

            string sql = string.Format("select top {0} pointid, point,jd_qClassID {1} {2} and pointid not in (select top {3} pointid {1} {2} {4}) {4}", count, from, where, start, order);

            myDataBase db = newDataBase.getDataBase();
            return db.GetDataReader(sql);
        }
        public static void InToNew(int start, int count)
        {
            SqlDataReader dr = GetOldDataReader(start, count);
            myDataBase db = newDataBase.getDataBase();
            while (dr.Read())
            {
                string sql = "insert into jd_qClassPoint( jd_qClassPointName, jd_qClassID,jd_qClassPointOID)";
                sql += "values(@qClassPointName, @qClassID,@qClassPointOID)";

                SqlParameter[] parames ={
                    myDataBase.CreateParameter("qClassPointName",SqlDbType.NVarChar,20,dr["point"]==null?"":dr["point"]),
                    myDataBase.CreateParameter("qClassID",SqlDbType.Int,4,dr["jd_qClassID"]==null?"":dr["jd_qClassID"]),
                    myDataBase.CreateParameter("qClassPointOID",SqlDbType.Int,4,dr["pointid"])
                };
                db.RunSql(sql, parames);
            }
            dr.Dispose();
        }
    }
}