SQLite导出数据到SQLServer

设计思路：数据导入到对应表需要单独操作，每次操作的逻辑基本一致，所以操作逻辑可以放在基类中，子类继承。设计如下：

using System; public interface IImportData { bool ImportData(); } public class SQLite2SqlServer : IImportData { public virtual bool ImportData() { // TODO: implement bool isSuccessful = true; dedestinationTableName = Destination; using (SQLiteDataReader reader = SQLiteHelper.ExecuteReader(SQL_SQLite)) using (System.Data.SqlClient.SqlBulkCopy bulkCopy = new System.Data.SqlClient.SqlBulkCopy(PubConstant.ConnectionString)) { { bulkCopy.DestinationTableName = Destination; try { bulkCopy.WriteToServer(reader); } catch (Exception ex) { isSuccessful = false; throw new Exception(ex.Message); } } } return isSuccessful; } public virtual bool Hook<T>() { // TODO: implement Type t = typeof(T); T dal = (T)Assembly.GetAssembly(t).CreateInstance(t.FullName); //XPWY.DAL.QuestionFace dal = new DAL.QuestionFace(); MethodInfo methodInfo = dal.GetType().GetMethod("GetList",new Type[]{typeof(string)}); DataSet ds = methodInfo.Invoke(dal,new String[] { " BatchID=" + this.BatchID.ToString() }) as DataSet; //GetList(" BatchID=" + this.BatchID.ToString()); if (ds != null && ds.Tables != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0) { return true; } else { return false; } } public virtual bool ImportDataFromSQLiteToSQLServer<T>() { // TODO: implement if(Hook<T>) { return ImportData(); } return false; } public System.Int32 BatchID; public System.String Destination; public System.String SQL_SQLite; } public class QuestionFace : SQLite2SqlServer { public QuestionFace(System.Int32 nBatchID) { this.BatchID = nBatchID; this.Destination="QuetionFace"; this.SQL_SQLite="select * from QuestionFace"; } public sealed bool ImportDataFromSQLiteToSQLServer() { // TODO: implement return base.ImportDataFromSQLiteToSQLServer<QuestionFace>(); } }

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!