transitionqclass.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.qClass
{
    public class TransitionqClass
    {
        public static int GetOldTotalCount()
        {
            string sql = "select count(*) from exam_class where deleted=0";
            myDataBase db = oldDataBase.getDataBase();
            return db.GetFirstInt(sql);
        }
        private static SqlDataReader GetOldDataReader(int start, int count)
        {
            string order = " order by classid";
            string where = "where deleted=0";
            string from = "from exam_class";
            string sql = string.Format("select top {0} classname,classid {1} {2} and classid not in (select top {4} classid {1} {2} {3}) {3}", count, from, where, order, start);
            myDataBase db = oldDataBase.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_qClass(jd_qClassName, jd_qClassOrder, jd_qClassOID) values(@qClassName, @qClassOrder, @qClassOID)";

                SqlParameter[] parames ={
                    myDataBase.CreateParameter("qClassName",SqlDbType.NVarChar,50,dr["classname"]==null?"":dr["classname"]),
                    myDataBase.CreateParameter("qClassOrder",SqlDbType.Int,4,0),
                    myDataBase.CreateParameter("qClassOID",SqlDbType.Int,4,dr["classid"])
                };
                db.RunSql(sql, parames);
            }
            dr.Dispose();
        }
    }
}