使用entitiy

时间：2017-03-21 15:12:12 阅读：265 评论：0 收藏：0 [点我收藏+]

标签：procedure 表名 import blocks color rom screen splay lis

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using System.Data;
  6 using System.Data.SqlClient;
  7 
  8 namespace SQL
  9 {
 10     public class DBParse
 11     {
 12         /// <summary>
 13         /// 獲取DB中所有的表格
 14         /// </summary>
 15         /// <returns></returns>
 16         public List<TableEntity> GetAllTable()
 17         {
 18             string sql = "SELECT Name FROM SysObjects Where XType=‘U‘ ORDER BY Name";
 19             DataTable dt = DbHelperSQL.Query(sql).Tables[0];
 20             List<TableEntity> list = new List<TableEntity>();
 21             if (dt != null && dt.Rows.Count > 0)
 22             {
 23                 foreach (DataRow dr in dt.Rows)
 24                 {
 25                     TableEntity entity = new TableEntity() { TableName = dr["Name"].ToString() };
 26                     list.Add(entity);
 27                 }
 28             }
 29 
 30             return list;
 31         }
 32 
 33         public List<TableInfoEntity> GetTableInfo(string tablename)
 34         {
 35             string strProc = "sp_columns";
 36             SqlParameter[] parameters = {
 37                     new SqlParameter("@table_name", SqlDbType.VarChar,50)
 38                                         };
 39             parameters[0].Value = tablename;
 40             DataTable dt = DbHelperSQL.RunProcedure(strProc,parameters,tablename).Tables[0];
 41             List<TableInfoEntity> list = new List<TableInfoEntity>();
 42             List<TablePKEntity> list_PK = GetTablePK(tablename);
 43             string strPK = "";
 44             string strpk_name = "";
 45             foreach (TablePKEntity pk in list_PK)
 46             {
 47                 strPK += pk.PK_ColumnName + ",";
 48             }
 49             if (list_PK != null && list_PK.Count > 0)
 50             {
 51                 if (!string.IsNullOrWhiteSpace(list_PK[0].PK_Name))
 52                 {
 53                     strpk_name = list_PK[0].PK_Name;
 54                 }
 55             }
 56             strPK = strPK.TrimEnd(‘,‘);
 57             if (dt != null && dt.Rows.Count > 0)
 58             {
 59                 foreach (DataRow dr in dt.Rows)
 60                 {
 61                     TableInfoEntity entity = new TableInfoEntity() ;
 62                     entity.TableName = dr["TABLE_NAME"].ToString().Trim().Replace("\t", "");
 63                     entity.ColumnName = dr["COLUMN_NAME"].ToString().Trim().Replace("\t", "");
 64                     entity.TypeName = dr["TYPE_NAME"].ToString();
 65                     entity.Precision = Convert.ToInt32(dr["PRECISION"].ToString());
 66                     entity.SCALE = dr["SCALE"] == System.DBNull.Value ? 0 : Convert.ToInt32(dr["SCALE"].ToString());
 67                     entity.Nullable = dr["NULLABLE"].ToString().Trim() == "0" ? false : true;
 68                     entity.IsIdentity = dr["TYPE_NAME"].ToString().Contains("identity") ? true : false;
 69                     entity.IsPK = list_PK.Where(q => q.PK_ColumnName == dr["COLUMN_NAME"].ToString()).Count() > 0 ? true : false;
 70                     entity.PKColumn = strPK;
 71                     entity.PK_Name = strpk_name.Replace(" ", "").Replace(" ", "").Replace(" ", "").Replace(" ", "").Replace("\t","").Replace(".","");
 72                     list.Add(entity);
 73                 }
 74             }
 75 
 76             return list;
 77         }
 78 
 79         /// <summary>
 80         /// 獲取表格的主鍵
 81         /// </summary>
 82         /// <param name="tablename">表格名稱</param>
 83         /// <returns></returns>
 84         public List<TablePKEntity> GetTablePK(string tablename)
 85         {
 86             string strProc = "sp_pkeys";
 87             SqlParameter[] parameters = {
 88                     new SqlParameter("@table_name", SqlDbType.VarChar,50)
 89                                         };
 90             parameters[0].Value = tablename;
 91             DataTable dt = DbHelperSQL.RunProcedure(strProc, parameters, tablename).Tables[0];
 92             List<TablePKEntity> list = new List<TablePKEntity>();
 93             if (dt != null && dt.Rows.Count > 0)
 94             {
 95                 foreach (DataRow dr in dt.Rows)
 96                 {
 97                     TablePKEntity entity = new TablePKEntity();
 98                     entity.TableName = dr["TABLE_NAME"].ToString().Trim().Replace("\t","");
 99                     entity.PK_ColumnName = dr["COLUMN_NAME"].ToString().Trim().Replace("\t", "");
100                     entity.PK_Name = dr["PK_NAME"].ToString();
101                     list.Add(entity);
102                 }
103             }
104             return list;
105         }
106 
107         public DataTable GetTableData(string querySql)
108         {
109             DataTable dt = DbHelperSQL.Query(querySql).Tables[0];
110             return dt;
111         }
112 
113         public int ExcuteSql(List<string> sql)
114         {
115             return DbHelperSQL.ExecuteSqlTran(sql);
116         }
117     }
118 }

View Code

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using System.Data.SQLite;
  6 using System.IO;
  7 using System.Data;
  8 
  9 namespace SQL2Sqlite
 10 {
 11     public class BaseHelper
 12     {
 13         //日志文件生命周期的时间标记
 14         //private static DateTime TimeSign;
 15         public Dictionary<string, string> dicSqlInsert = new Dictionary<string, string>();
 16         public Dictionary<string, string> dicSqlQuery = new Dictionary<string, string>();
 17         private string GetDBName()
 18         {
 19             DateTime now = DateTime.Now;
 20 
 21             string name = "FB_Proposal" + now.ToString("yyyyMMdd") + ".db";
 22             if (!File.Exists(name))
 23             {
 24                 //創建DB
 25                 createNewDatabase(name);
 26                 //創建Table
 27                 //CreateTable(name);
 28             }
 29             return name;
 30         }
 31         //创建一个空的数据库
 32         private void createNewDatabase(string name)
 33         { 
 34            SQLiteConnection.CreateFile(name);
 35         }
 36         private void CreateTable(string name)
 37         {
 38             string sql = "create table YouKeyBorad (addtime INTEGER, keyvalue varchar(10));create table YouScreen (addtime INTEGER, screenimg TEXT)";
 39             SQLiteConnection conn = new SQLiteConnection(string.Format("Data Source={0};Version=3;UseUTF8Encoding=True;", name));
 40             SQLiteCommand command = new SQLiteCommand(sql, conn);
 41             conn.Open();
 42             command.ExecuteNonQuery();
 43             conn.Close();
 44         }
 45         public SQLiteConnection Connect()
 46         {
 47             SQLiteConnection m_dbConnection = new SQLiteConnection(string.Format("Data Source={0};Version=3;UseUTF8Encoding=True;", GetDBName()));
 48             return m_dbConnection;
 49         }
 50 
 51         public  bool CreateTable2(string tablename)
 52         {
 53 
 54             bool retbool = false;
 55             StringBuilder strSql = new StringBuilder();
 56             //生成 插入數據的SQl語句
 57             StringBuilder strSql_insert = new StringBuilder();
 58             StringBuilder strSql_Query = new StringBuilder();
 59             try
 60             {
 61                 strSql.Append(" create table ");
 62                 strSql.Append("[" + tablename.TrimEnd() + "]");
 63                 strSql.Append(" ( ");
 64                 DBParse dbSQL = new DBParse();
 65                 List<TableInfoEntity> list = dbSQL.GetTableInfo(tablename);
 66                 //foreach (TableInfoEntity entity in list)
 67                 string strPK = "";
 68                 string strpk_name = "";
 69                 strSql_insert.AppendFormat(" insert into {0} values(", tablename);
 70                 strSql_Query.Append("select ");
 71                 //拼接創建表的SQL
 72                 for (int i = 0; i < list.Count; i++)
 73                 {
 74                     TableInfoEntity entity = list[i];
 75                     #region 拼接創建表 SQL
 76                     strSql.Append("[" + entity.ColumnName + "]");
 77                     strSql.Append(" ");
 78                     strSql.Append(SQLType2SQLiteType.SqlTypeString2SqliteType(entity.TypeName, entity.Precision, entity.SCALE));
 79 
 80                     if (!entity.Nullable)
 81                     {
 82                         strSql.Append("  NOT NULL ");
 83                     }
 84                     
 85                     //if (entity.IsIdentity)
 86                     //{
 87                     //    strSql.Append(" AUTOINCREMENT ");
 88                     //}
 89                     #endregion
 90                     #region 拼接插入數據的SQL
 91                     if (entity.TypeName.ToLower().Equals("varchar") || entity.TypeName.ToLower().Equals("ntext")
 92                      || entity.TypeName.ToLower().Equals("nvarchar") || entity.TypeName.ToLower().Equals("text")
 93                      || entity.TypeName.ToLower().Equals("char") || entity.TypeName.ToLower().Equals("nchar")
 94                      || entity.TypeName.ToLower().Equals("bit") || entity.TypeName.ToLower().Equals("datetime")
 95                      || entity.TypeName.ToLower().Equals("date") || entity.TypeName.ToLower().Equals("time"))
 96                     {
 97                         strSql_insert.Append(" ‘{");
 98                     }
 99                     else
100                     {
101                         strSql_insert.Append(" {");
102                     }
103                     if (entity.TypeName.Equals("System.DateTime") || entity.TypeName.ToLower().Contains("datetime"))
104                     {
105                         strSql_insert.Append(i + ":yyyy-MM-dd HH:mm:ss.fff");
106                     }
107                     else
108                     {
109                         strSql_insert.Append(i);
110                     }
111                     //strSql_insert.Append(i);
112                     if (entity.TypeName.ToLower().Equals("varchar") || entity.TypeName.ToLower().Equals("ntext")
113                      || entity.TypeName.ToLower().Equals("nvarchar") || entity.TypeName.ToLower().Equals("text")
114                      || entity.TypeName.ToLower().Equals("char") || entity.TypeName.ToLower().Equals("nchar")
115                      || entity.TypeName.ToLower().Equals("bit") || entity.TypeName.ToLower().Equals("datetime")
116                      || entity.TypeName.ToLower().Equals("date") || entity.TypeName.ToLower().Equals("time"))
117                     {
118                         strSql_insert.Append("}‘");
119                     }
120                     else
121                     {
122                         strSql_insert.Append("}");
123                     }
124                     #endregion
125                     #region 拼接查詢數據的SQL
126                     strSql_Query.Append("[" + entity.ColumnName + "]");
127                     #endregion
128                     if (i < list.Count - 1)
129                     {
130                         strSql.Append(",");
131                         strSql_insert.Append(",");
132                         strSql_Query.Append(",");
133                     }
134                     strPK = entity.PKColumn;
135                     strpk_name = entity.PK_Name;
136                 }
137                 //給表添加主鍵
138                 if (strPK != "")
139                 {
140                     if (strpk_name.Trim() == "")
141                     {
142                         strpk_name = "pk_" + tablename.TrimEnd();
143                     }
144                     strSql.AppendFormat(" ,constraint {0} primary key ({1}) ", strpk_name, strPK);
145                 }
146                 strSql.Append(" ) ");
147                 strSql_insert.Append(" );");
148                 strSql_Query.Append(" from " + tablename.TrimEnd());
149                 SQLiteHelper.ExecuteNonQuery(Connect(), strSql.ToString());
150                 retbool = true;
151                 dicSqlInsert.Add(tablename.TrimEnd(), strSql_insert.ToString());
152                 dicSqlQuery.Add(tablename.TrimEnd(), strSql_Query.ToString());
153             }
154             catch (Exception ee)
155             {
156                 MyConsole.WriteLine(ee.Message + "----" + strSql.ToString());
157                 retbool = false;
158             }
159             return retbool;
160         }
161 
162         public int ImportData(string querySql,string intoSql)
163         {  
164             int retInt = 0;
165             DBParse dbSQL = new DBParse();
166             DataTable dtSqlData = dbSQL.GetTableData(querySql);
167             //最後的執行insert的SQL語句
168             List<string> listSql = new List<string>();
169             if (dtSqlData != null && dtSqlData.Rows.Count > 0)
170             {
171                 for (int i = 0; i < dtSqlData.Rows.Count; i++)
172                 {
173                     try
174                     {
175                         string sqlTemp = "";
176                         object[] args = new object[dtSqlData.Columns.Count];
177                         object objtemp = null;
178                         bool haveNull = false;
179                         for (int j = 0; j < dtSqlData.Columns.Count; j++)
180                         {
181                             //MyConsole.TransferEncoding(Encoding.Default, Encoding.UTF8, dtSqlData.Rows[i][j].ToString());
182                             if (intoSql.Contains("PIA_LOG_MAIN"))
183                             {
184                                 break;
185                             }
186                             //if (intoSql.Contains("tbNews"))
187                             //{
188                             //    int x = 0;
189                             //}
190                             if (dtSqlData.Rows[i][j] == DBNull.Value || dtSqlData.Columns[j].DataType == Type.GetType("System.Byte[]"))
191                             {
192                                 args[j] = "Null";
193                                 sqlTemp = intoSql.Replace("‘{" + j + "}‘", "{" + j + "}");
194                                 haveNull = true;
195                             }
196                             else if (dtSqlData.Columns[j].DataType == Type.GetType("System.Boolean"))
197                             {
198                                 args[j] = Convert.ToBoolean(dtSqlData.Rows[i][j]) ? 1 : 0; 
199                             }
200                             else
201                             {
202                                 if (dtSqlData.Rows[i][j].ToString().Contains(@"‘"))
203                                 {
204                                     args[j] = dtSqlData.Rows[i][j].ToString().Replace(@"‘", @"‘‘");
205                                 }
206                                 else
207                                 {
208                                     args[j] = dtSqlData.Rows[i][j];
209                                 }
210                             }
211                         }
212                         string into_temp = "";
213                         if (haveNull)
214                         {
215                             into_temp = string.Format(sqlTemp, args);
216                         }
217                         else
218                         {
219                             into_temp = string.Format(intoSql, args);
220                         }
221                         //string into_temp = string.Format(intoSql, args);
222                         listSql.Add(into_temp.Replace("‘Null‘","Null"));
223                         if (listSql.Count == 500)
224                         {
225                             int temp = ExecuteSQL(listSql);
226                             if (temp == 0)
227                             {
228                                 Logger.Error(listSql.ToString());
229                                 MyConsole.WriteLine("有500條導入數據的事務出現異常，已放棄：" + intoSql);
230                             }
231                             retInt += temp;
232                             listSql.Clear();
233                         }
234                     }
235                     catch (Exception ex)
236                     {
237                         MyConsole.WriteLine(ex.Message);
238                     }
239                 }
240                 if (listSql.Count > 0)
241                 {
242                     //retInt += ExecuteSQL(listSql);
243                     int temp = ExecuteSQL(listSql);
244                     if (temp == 0)
245                     {
246                         MyConsole.WriteLine("有部分導入數據的事務出現異常，已放棄：" + intoSql);
247                     }
248                     retInt += temp;
249                 }
250             }
251             return retInt;
252         }
253 
254         private int ExecuteSQL(List<string> intoSql)
255         {
256             return SQLiteHelper.ExecuteSqlTran(Connect(),intoSql);
257         }
258 
259     }
260 }

從數據庫中得到數據

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using System.Data;
  6 using System.Data.SqlClient;
  7 
  8 namespace SQL2Sqlite
  9 {
 10     public class DBParse
 11     {
 12         /// <summary>
 13         /// 獲取DB中所有的表格
 14         /// </summary>
 15         /// <returns></returns>
 16         public List<TableEntity> GetAllTable()
 17         {
 18             string sql = "SELECT Name FROM SysObjects Where XType=‘U‘ ORDER BY Name";
 19             DataTable dt = DbHelperSQL.Query(sql).Tables[0];
 20             List<TableEntity> list = new List<TableEntity>();
 21             if (dt != null && dt.Rows.Count > 0)
 22             {
 23                 foreach (DataRow dr in dt.Rows)
 24                 {
 25                     TableEntity entity = new TableEntity() { TableName = dr["Name"].ToString() };
 26                     list.Add(entity);
 27                 }
 28             }
 29 
 30             return list;
 31         }
 32 
 33         public List<TableInfoEntity> GetTableInfo(string tablename)
 34         {
 35             string strProc = "sp_columns";
 36             SqlParameter[] parameters = {
 37                     new SqlParameter("@table_name", SqlDbType.VarChar,50)
 38                                         };
 39             parameters[0].Value = tablename;
 40             DataTable dt = DbHelperSQL.RunProcedure(strProc,parameters,tablename).Tables[0];
 41             List<TableInfoEntity> list = new List<TableInfoEntity>();
 42             List<TablePKEntity> list_PK = GetTablePK(tablename);
 43             string strPK = "";
 44             string strpk_name = "";
 45             foreach (TablePKEntity pk in list_PK)
 46             {
 47                 strPK += pk.PK_ColumnName + ",";
 48             }
 49             if (list_PK != null && list_PK.Count > 0)
 50             {
 51                 if (!string.IsNullOrWhiteSpace(list_PK[0].PK_Name))
 52                 {
 53                     strpk_name = list_PK[0].PK_Name;
 54                 }
 55             }
 56             strPK = strPK.TrimEnd(‘,‘);
 57             if (dt != null && dt.Rows.Count > 0)
 58             {
 59                 foreach (DataRow dr in dt.Rows)
 60                 {
 61                     TableInfoEntity entity = new TableInfoEntity() ;
 62                     entity.TableName = dr["TABLE_NAME"].ToString().Trim().Replace("\t", "");
 63                     entity.ColumnName = dr["COLUMN_NAME"].ToString().Trim().Replace("\t", "");
 64                     entity.TypeName = dr["TYPE_NAME"].ToString();
 65                     entity.Precision = Convert.ToInt32(dr["PRECISION"].ToString());
 66                     entity.SCALE = dr["SCALE"] == System.DBNull.Value ? 0 : Convert.ToInt32(dr["SCALE"].ToString());
 67                     entity.Nullable = dr["NULLABLE"].ToString().Trim() == "0" ? false : true;
 68                     entity.IsIdentity = dr["TYPE_NAME"].ToString().Contains("identity") ? true : false;
 69                     entity.IsPK = list_PK.Where(q => q.PK_ColumnName == dr["COLUMN_NAME"].ToString()).Count() > 0 ? true : false;
 70                     entity.PKColumn = strPK;
 71                     entity.PK_Name = strpk_name.Replace(" ", "").Replace(" ", "").Replace(" ", "").Replace(" ", "").Replace("\t","").Replace(".","");
 72                     list.Add(entity);
 73                 }
 74             }
 75 
 76             return list;
 77         }
 78 
 79         /// <summary>
 80         /// 獲取表格的主鍵
 81         /// </summary>
 82         /// <param name="tablename">表格名稱</param>
 83         /// <returns></returns>
 84         public List<TablePKEntity> GetTablePK(string tablename)
 85         {
 86             string strProc = "sp_pkeys";
 87             SqlParameter[] parameters = {
 88                     new SqlParameter("@table_name", SqlDbType.VarChar,50)
 89                                         };
 90             parameters[0].Value = tablename;
 91             DataTable dt = DbHelperSQL.RunProcedure(strProc, parameters, tablename).Tables[0];
 92             List<TablePKEntity> list = new List<TablePKEntity>();
 93             if (dt != null && dt.Rows.Count > 0)
 94             {
 95                 foreach (DataRow dr in dt.Rows)
 96                 {
 97                     TablePKEntity entity = new TablePKEntity();
 98                     entity.TableName = dr["TABLE_NAME"].ToString().Trim().Replace("\t","");
 99                     entity.PK_ColumnName = dr["COLUMN_NAME"].ToString().Trim().Replace("\t", "");
100                     entity.PK_Name = dr["PK_NAME"].ToString();
101                     list.Add(entity);
102                 }
103             }
104             return list;
105         }
106 
107         public DataTable GetTableData(string querySql)
108         {
109             DataTable dt = DbHelperSQL.Query(querySql).Tables[0];
110             return dt;
111         }
112 
113         public int ExcuteSql(List<string> sql)
114         {
115             return DbHelperSQL.ExecuteSqlTran(sql);
116         }
117     }
118 }

得到表的信息

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Text;
 5 
 6 namespace SQL2Sqlite
 7 {
 8     public class Entity
 9     {
10 
11     }
12 
13     /// <summary>
14     /// 數據庫內所有的表格
15     /// </summary>
16     public class TableEntity
17     {
18         public string TableName { get; set; }
19     }
20 
21     /// <summary>
22     /// 表格對象
23     /// </summary>
24     public class TableInfoEntity
25     {
26         /// <summary>
27         /// 表名
28         /// </summary>
29         public string TableName { get; set; }
30         /// <summary>
31         /// 列名
32         /// </summary>
33         public string ColumnName { get; set; }
34         /// <summary>
35         /// 列類型名
36         /// </summary>
37         public string TypeName { get; set; }
38         /// <summary>
39         /// 列類型的長度
40         /// </summary>
41         public int Precision { get; set; }
42 
43         /// <summary>
44         /// 列類型的小數位
45         /// </summary>
46         public int SCALE { get; set; }
47 
48         /// <summary>
49         /// 列是否可以為空 true可以為空，false不能為空
50         /// </summary>
51         public bool Nullable { get; set; }
52 
53         /// <summary>
54         /// 是否自動增長 true為自動增長
55         /// </summary>
56         public bool IsIdentity { get; set; }
57 
58         /// <summary>
59         /// 是否為主鍵  true為主鍵
60         /// </summary>
61         public bool IsPK { get; set; }
62 
63         /// <summary>
64         /// 所有的主鍵列，逗號隔開
65         /// </summary>
66         public string PKColumn { get; set; }
67         /// <summary>
68         /// 主鍵名
69         /// </summary>
70         public string PK_Name { get; set; }
71 
72     }
73 
74     /// <summary>
75     /// 表格主鍵名
76     /// </summary>
77     public class TablePKEntity
78     {
79         /// <summary>
80         /// 表名
81         /// </summary>
82         public string TableName { get; set; }
83         /// <summary>
84         /// 主鍵列名
85         /// </summary>
86         public string PK_ColumnName { get; set; }
87 
88         /// <summary>
89         /// 主鍵名
90         /// </summary>
91         public string PK_Name { get; set; }
92     }
93 }

實體

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Text;
  5 using System.Data.SQLite;
  6 using System.IO;
  7 using System.Data;
  8 
  9 namespace SQL2Sqlite
 10 {
 11     public class BaseHelper
 12     {
 13         //日志文件生命周期的时间标记
 14         //private static DateTime TimeSign;
 15         public Dictionary<string, string> dicSqlInsert = new Dictionary<string, string>();
 16         public Dictionary<string, string> dicSqlQuery = new Dictionary<string, string>();
 17         private string GetDBName()
 18         {
 19             DateTime now = DateTime.Now;
 20 
 21             string name = "FB_Proposal" + now.ToString("yyyyMMdd") + ".db";
 22             if (!File.Exists(name))
 23             {
 24                 //創建DB
 25                 createNewDatabase(name);
 26                 //創建Table
 27                 //CreateTable(name);
 28             }
 29             return name;
 30         }
 31         //创建一个空的数据库
 32         private void createNewDatabase(string name)
 33         { 
 34            SQLiteConnection.CreateFile(name);
 35         }
 36         private void CreateTable(string name)
 37         {
 38             string sql = "create table YouKeyBorad (addtime INTEGER, keyvalue varchar(10));create table YouScreen (addtime INTEGER, screenimg TEXT)";
 39             SQLiteConnection conn = new SQLiteConnection(string.Format("Data Source={0};Version=3;UseUTF8Encoding=True;", name));
 40             SQLiteCommand command = new SQLiteCommand(sql, conn);
 41             conn.Open();
 42             command.ExecuteNonQuery();
 43             conn.Close();
 44         }
 45         public SQLiteConnection Connect()
 46         {
 47             SQLiteConnection m_dbConnection = new SQLiteConnection(string.Format("Data Source={0};Version=3;UseUTF8Encoding=True;", GetDBName()));
 48             return m_dbConnection;
 49         }
 50 
 51         public  bool CreateTable2(string tablename)
 52         {
 53 
 54             bool retbool = false;
 55             StringBuilder strSql = new StringBuilder();
 56             //生成 插入數據的SQl語句
 57             StringBuilder strSql_insert = new StringBuilder();
 58             StringBuilder strSql_Query = new StringBuilder();
 59             try
 60             {
 61                 strSql.Append(" create table ");
 62                 strSql.Append("[" + tablename.TrimEnd() + "]");
 63                 strSql.Append(" ( ");
 64                 DBParse dbSQL = new DBParse();
 65                 List<TableInfoEntity> list = dbSQL.GetTableInfo(tablename);
 66                 //foreach (TableInfoEntity entity in list)
 67                 string strPK = "";
 68                 string strpk_name = "";
 69                 strSql_insert.AppendFormat(" insert into {0} values(", tablename);
 70                 strSql_Query.Append("select ");
 71                 //拼接創建表的SQL
 72                 for (int i = 0; i < list.Count; i++)
 73                 {
 74                     TableInfoEntity entity = list[i];
 75                     #region 拼接創建表 SQL
 76                     strSql.Append("[" + entity.ColumnName + "]");
 77                     strSql.Append(" ");
 78                     strSql.Append(SQLType2SQLiteType.SqlTypeString2SqliteType(entity.TypeName, entity.Precision, entity.SCALE));
 79 
 80                     if (!entity.Nullable)
 81                     {
 82                         strSql.Append("  NOT NULL ");
 83                     }
 84                     
 85                     //if (entity.IsIdentity)
 86                     //{
 87                     //    strSql.Append(" AUTOINCREMENT ");
 88                     //}
 89                     #endregion
 90                     #region 拼接插入數據的SQL
 91                     if (entity.TypeName.ToLower().Equals("varchar") || entity.TypeName.ToLower().Equals("ntext")
 92                      || entity.TypeName.ToLower().Equals("nvarchar") || entity.TypeName.ToLower().Equals("text")
 93                      || entity.TypeName.ToLower().Equals("char") || entity.TypeName.ToLower().Equals("nchar")
 94                      || entity.TypeName.ToLower().Equals("bit") || entity.TypeName.ToLower().Equals("datetime")
 95                      || entity.TypeName.ToLower().Equals("date") || entity.TypeName.ToLower().Equals("time"))
 96                     {
 97                         strSql_insert.Append(" ‘{");
 98                     }
 99                     else
100                     {
101                         strSql_insert.Append(" {");
102                     }
103                     if (entity.TypeName.Equals("System.DateTime") || entity.TypeName.ToLower().Contains("datetime"))
104                     {
105                         strSql_insert.Append(i + ":yyyy-MM-dd HH:mm:ss.fff");
106                     }
107                     else
108                     {
109                         strSql_insert.Append(i);
110                     }
111                     //strSql_insert.Append(i);
112                     if (entity.TypeName.ToLower().Equals("varchar") || entity.TypeName.ToLower().Equals("ntext")
113                      || entity.TypeName.ToLower().Equals("nvarchar") || entity.TypeName.ToLower().Equals("text")
114                      || entity.TypeName.ToLower().Equals("char") || entity.TypeName.ToLower().Equals("nchar")
115                      || entity.TypeName.ToLower().Equals("bit") || entity.TypeName.ToLower().Equals("datetime")
116                      || entity.TypeName.ToLower().Equals("date") || entity.TypeName.ToLower().Equals("time"))
117                     {
118                         strSql_insert.Append("}‘");
119                     }
120                     else
121                     {
122                         strSql_insert.Append("}");
123                     }
124                     #endregion
125                     #region 拼接查詢數據的SQL
126                     strSql_Query.Append("[" + entity.ColumnName + "]");
127                     #endregion
128                     if (i < list.Count - 1)
129                     {
130                         strSql.Append(",");
131                         strSql_insert.Append(",");
132                         strSql_Query.Append(",");
133                     }
134                     strPK = entity.PKColumn;
135                     strpk_name = entity.PK_Name;
136                 }
137                 //給表添加主鍵
138                 if (strPK != "")
139                 {
140                     if (strpk_name.Trim() == "")
141                     {
142                         strpk_name = "pk_" + tablename.TrimEnd();
143                     }
144                     strSql.AppendFormat(" ,constraint {0} primary key ({1}) ", strpk_name, strPK);
145                 }
146                 strSql.Append(" ) ");
147                 strSql_insert.Append(" );");
148                 strSql_Query.Append(" from " + tablename.TrimEnd());
149                 SQLiteHelper.ExecuteNonQuery(Connect(), strSql.ToString());
150                 retbool = true;
151                 dicSqlInsert.Add(tablename.TrimEnd(), strSql_insert.ToString());
152                 dicSqlQuery.Add(tablename.TrimEnd(), strSql_Query.ToString());
153             }
154             catch (Exception ee)
155             {
156                 MyConsole.WriteLine(ee.Message + "----" + strSql.ToString());
157                 retbool = false;
158             }
159             return retbool;
160         }
161 
162         public int ImportData(string querySql,string intoSql)
163         {  
164             int retInt = 0;
165             DBParse dbSQL = new DBParse();
166             DataTable dtSqlData = dbSQL.GetTableData(querySql);
167             //最後的執行insert的SQL語句
168             List<string> listSql = new List<string>();
169             if (dtSqlData != null && dtSqlData.Rows.Count > 0)
170             {
171                 for (int i = 0; i < dtSqlData.Rows.Count; i++)
172                 {
173                     try
174                     {
175                         string sqlTemp = "";
176                         object[] args = new object[dtSqlData.Columns.Count];
177                         object objtemp = null;
178                         bool haveNull = false;
179                         for (int j = 0; j < dtSqlData.Columns.Count; j++)
180                         {
181                             //MyConsole.TransferEncoding(Encoding.Default, Encoding.UTF8, dtSqlData.Rows[i][j].ToString());
182                             if (intoSql.Contains("PIA_LOG_MAIN"))
183                             {
184                                 break;
185                             }
186                             //if (intoSql.Contains("tbNews"))
187                             //{
188                             //    int x = 0;
189                             //}
190                             if (dtSqlData.Rows[i][j] == DBNull.Value || dtSqlData.Columns[j].DataType == Type.GetType("System.Byte[]"))
191                             {
192                                 args[j] = "Null";
193                                 sqlTemp = intoSql.Replace("‘{" + j + "}‘", "{" + j + "}");
194                                 haveNull = true;
195                             }
196                             else if (dtSqlData.Columns[j].DataType == Type.GetType("System.Boolean"))
197                             {
198                                 args[j] = Convert.ToBoolean(dtSqlData.Rows[i][j]) ? 1 : 0; 
199                             }
200                             else
201                             {
202                                 if (dtSqlData.Rows[i][j].ToString().Contains(@"‘"))
203                                 {
204                                     args[j] = dtSqlData.Rows[i][j].ToString().Replace(@"‘", @"‘‘");
205                                 }
206                                 else
207                                 {
208                                     args[j] = dtSqlData.Rows[i][j];
209                                 }
210                             }
211                         }
212                         string into_temp = "";
213                         if (haveNull)
214                         {
215                             into_temp = string.Format(sqlTemp, args);
216                         }
217                         else
218                         {
219                             into_temp = string.Format(intoSql, args);
220                         }
221                         //string into_temp = string.Format(intoSql, args);
222                         listSql.Add(into_temp.Replace("‘Null‘","Null"));
223                         if (listSql.Count == 500)
224                         {
225                             int temp = ExecuteSQL(listSql);
226                             if (temp == 0)
227                             {
228                                 Logger.Error(listSql.ToString());
229                                 MyConsole.WriteLine("有500條導入數據的事務出現異常，已放棄：" + intoSql);
230                             }
231                             retInt += temp;
232                             listSql.Clear();
233                         }
234                     }
235                     catch (Exception ex)
236                     {
237                         MyConsole.WriteLine(ex.Message);
238                     }
239                 }
240                 if (listSql.Count > 0)
241                 {
242                     //retInt += ExecuteSQL(listSql);
243                     int temp = ExecuteSQL(listSql);
244                     if (temp == 0)
245                     {
246                         MyConsole.WriteLine("有部分導入數據的事務出現異常，已放棄：" + intoSql);
247                     }
248                     retInt += temp;
249                 }
250             }
251             return retInt;
252         }
253 
254         private int ExecuteSQL(List<string> intoSql)
255         {
256             return SQLiteHelper.ExecuteSqlTran(Connect(),intoSql);
257         }
258 
259     }
260 }

DBHelper

使用entitiy

标签：procedure 表名 import blocks color rom screen splay lis

原文地址：http://www.cnblogs.com/whl4835349/p/6594123.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行