users.cs

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

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

namespace Transition.User
{
    public class TransitionUser
    {
        
        public static int GetOldTotalCount()
        {
            myDataBase db = oldDataBase.getDataBase();
            db.Name = "Club";
            string sql = "select count(*) from user_info";
            return db.GetFirstInt(sql);
        }
        public static SqlDataReader GetOldDataReader(int start,int count)
        {
            myDataBase db = oldDataBase.getDataBase();
            db.Name = "Club";
            string from = "from user_info left join Examination.dbo.loginuser on users=[user_name]";
            string select = "user_name, user_password, user_email, user_question, user_answer, user_qq, User_Realname, User_Province, User_PostCode, User_Address, User_Telphone, User_Fax, User_Mobile, User_CorpName, user_home,  user_sex,userlevel,[user_id]";
            string sql="";
            if (start == 0)
            {
                sql = string.Format("select top {0} {1} {2}", count, select, from);
            }
            else
            {
                sql = "declare @start int;";
                sql += string.Format("set @start= (select max([user_id]) from (select top {0} [user_id] {1}) as TT );",start,from);
                sql += string.Format("select top {0} {1} {2} where [user_id] >@start;", count, select, from);
            }

            //string from = "from user_info left join Examination.dbo.loginuser on users=[user_name]";
            //string select = "user_name, user_password, user_email, user_question, user_answer, user_qq, User_Realname, User_Province, User_PostCode, User_Address, User_Telphone, User_Fax, User_Mobile, User_CorpName, user_home,  user_sex,userlevel,[user_id]";
            //string sql = string.Format("select top {0} {1} {2} where [user_id] not in (select top {3} [user_id] {2})", count, select, from, start);
            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_User(jd_UserName, jd_UserPwd, jd_UserQuestion, jd_UserAnswer, jd_UserRealName, jd_UserPhoto, jd_UserSex, jd_UserProvince, jd_UserAddress, jd_UserPostCode, jd_UserTel, jd_UserFax, jd_UserCall, jd_UserQQ, jd_UserMail, jd_UserCommanyName, jd_UserCommanyWebSite, jd_uGroupID,user_id)";
                //sql += "values (@UserName, @UserPwd, @UserQuestion, @UserAnswer, @UserRealName, @UserPhoto, @UserSex, @UserProvince, @UserAddress, @UserPostCode, @UserTel, @UserFax, @UserCall, @UserQQ, @UserMail, @UserCommanyName, @UserCommanyWebSite, @uGroupID,@user_id)";
                string sql = "insert into jd_User(jd_UserPhoto,jd_uGroupID,jd_UserRealName,jd_UserSex,jd_UserTel,jd_UserAddress,user_id)";
                sql += "values (@UserPhoto,@uGroupID,@UserRealName,@UserSex,@UserTel,@UserAddress,@user_id)";
                SqlParameter[] parames ={
                    myDataBase.CreateParameter("uGroupID",SqlDbType.Int,4,setGroupID(dr["userlevel"])),
                    myDataBase.CreateParameter("user_id",SqlDbType.Int,4,dr["user_id"]),
                    myDataBase.CreateParameter("UserPhoto",SqlDbType.NVarChar,255,""),
                    myDataBase.CreateParameter("UserRealName",SqlDbType.NVarChar,20,dr["User_Realname"]==null?"":dr["User_Realname"].ToString().Trim()),
                    myDataBase.CreateParameter("UserSex",SqlDbType.Bit,1,setSex(dr["user_sex"])), 
                    myDataBase.CreateParameter("UserTel",SqlDbType.VarChar,20,dr["User_Telphone"]==null?"":dr["User_Telphone"].ToString().Trim()),
                    myDataBase.CreateParameter("UserAddress",SqlDbType.NVarChar,200,dr["User_Address"]==null?"":dr["User_Address"].ToString().Trim())
                };
                //SqlParameter[] parames ={
                //    myDataBase.CreateParameter("UserName",SqlDbType.NVarChar,20,dr["user_name"]==null?"":dr["user_name"]),
                //    myDataBase.CreateParameter("UserPwd",SqlDbType.NVarChar,32,dr["user_password"]==null?"":dr["user_password"]),
                //    myDataBase.CreateParameter("UserQuestion",SqlDbType.NVarChar,100,dr["user_question"]==null?"":dr["user_question"]),
                //    myDataBase.CreateParameter("UserAnswer",SqlDbType.NVarChar,100,dr["user_answer"]==null?"":dr["user_answer"]),
                //    myDataBase.CreateParameter("UserRealName",SqlDbType.NVarChar,20,dr["User_Realname"]==null?"":dr["User_Realname"]),
                //    myDataBase.CreateParameter("UserPhoto",SqlDbType.NVarChar,255,""),
                //    myDataBase.CreateParameter("UserSex",SqlDbType.Bit,1,setSex(dr["user_sex"])), 
                //    myDataBase.CreateParameter("UserProvince",SqlDbType.NVarChar,20,dr["User_Province"]==null?"":dr["User_Province"]),
                //    myDataBase.CreateParameter("UserAddress",SqlDbType.NVarChar,200,dr["User_Address"]==null?"":dr["User_Address"]),
                //    myDataBase.CreateParameter("UserPostCode",SqlDbType.VarChar,6,dr["User_PostCode"]==null?"":dr["User_PostCode"]),
                //    myDataBase.CreateParameter("UserTel",SqlDbType.VarChar,20,dr["User_Telphone"]==null?"":dr["User_Telphone"]),
                //    myDataBase.CreateParameter("UserFax",SqlDbType.VarChar,20,dr["User_Fax"]==null?"":dr["User_Fax"]),
                //    myDataBase.CreateParameter("UserCall",SqlDbType.VarChar,12,dr["User_Mobile"]==null?"":dr["User_Mobile"]),
                //    myDataBase.CreateParameter("UserMail",SqlDbType.NVarChar,50,dr["user_email"]==null?"":dr["user_email"]),
                //    myDataBase.CreateParameter("UserQQ",SqlDbType.VarChar,50,dr["user_qq"]==null?"":dr["user_qq"]),
                //    myDataBase.CreateParameter("UserCommanyName",SqlDbType.NVarChar,50,dr["User_CorpName"]==null?"":dr["User_CorpName"]),
                //    myDataBase.CreateParameter("UserCommanyWebSite",SqlDbType.VarChar,100,dr["user_home"]==null?"":dr["user_home"]),
                //    myDataBase.CreateParameter("user_id",SqlDbType.Int,4,dr["user_id"]),
                //    myDataBase.CreateParameter("uGroupID",SqlDbType.Int,4,setGroupID(dr["userlevel"]))
                //};
                db.RunSql(sql,parames);
            }
            dr.Dispose();
        }
        private static bool setSex(object usersex)
        {
            //设置性别
            bool sex = false;
            if (usersex == null || usersex.ToString().Trim() == "1" || usersex.ToString().Trim() == "男")
            {
                sex = true;
            }
            return sex;
        }
        private static int setGroupID(object userlevel)
        {
            int groupID = 9;

            /*
             * 7和其它普通用户-->9,
             * 6代理商-->8
             * 3培训部内部人员-->3
             * 1任我行员工-->4
             */
            if (userlevel == null || userlevel.ToString() == "0" || userlevel.ToString() == "7")
            {
                groupID = 9;
            }
            else if (userlevel.ToString() == "6")
            {
                groupID = 8;
            }
            else if (userlevel.ToString() == "3")
            {
                groupID = 3;
            }
            else if (userlevel.ToString() == "1")
            {
                groupID = 4;
            }
            else
            {
                groupID = 9;
            }
            return groupID;
        }
    }
}