连锁创建分店数据库方法

public void InitialData(string ModelDataBaseName, string DataBaseName)
 {
 #region 处理表和表数据
 string strSql_GetUserTable = string.Format("select * from {0}.dbo.GetUserTable order by id,columnsort ", ModelDataBaseName);
 DataTable dt_GetUserTable = dbHelper.ExecuteQuery(CommandType.Text, strSql_GetUserTable, null).Tables[0];
 if (dt_GetUserTable.Rows.Count > 0)
 { 
 //id,tablename,columnsort,columnname,tablekey,columndatatype,columndatalen1
 //columndatalen2,columndatafloat,allowisnull,defaultdata
 string tableName = "";
 StringBuilder strCreateTableSql = new StringBuilder();
 StringBuilder strKeySql = new StringBuilder();
 StringBuilder strInsertData = new StringBuilder();

 foreach (DataRow dr in dt_GetUserTable.Rows)
 {
 if (dr["tablename"].ToString() != tableName)
 {
 if (!string.IsNullOrEmpty(strCreateTableSql.ToString()))
 { 
 if (strKeySql.Length > 0)
 {
 strKeySql.Remove(strKeySql.Length - 1, 1);
 strCreateTableSql.AppendFormat(" PRIMARY KEY CLUSTERED ( {0} )) ON [PRIMARY] ", strKeySql.ToString());
 strKeySql.Remove(strKeySql.Length - 1, 1);

 }
 else
 {
 if (strCreateTableSql.ToString().EndsWith(","))
 strCreateTableSql.Remove(strCreateTableSql.Length - 1, 1);
 strCreateTableSql.Append(" )");
 }
 dbHelper.ExecuteNonQuery(DataBaseName, strCreateTableSql.ToString(), null);
 dbHelper.ExecuteNonQuery(CommandType.Text, string.Format(" insert into {0}.dbo.{1} select * from {2}.dbo.{1} ", DataBaseName, tableName, ModelDataBaseName), null);
 }
 tableName = dr["tablename"].ToString();
 strCreateTableSql.Clear(); strCreateTableSql = new StringBuilder();
 strKeySql.Clear(); strKeySql = new StringBuilder();
 strCreateTableSql.AppendFormat(" create table {0} (", tableName);
 }
 strCreateTableSql.Append(dbHelper.GetDataType(dr["columnname"].ToString(),dr["columndatatype"].ToString(), dbHelper.GetInt(dr["columndatalen2"].ToString()),
 dbHelper.GetInt(dr["columndatafloat"].ToString()), dr["allowisnull"].ToString(), dr["tablekey"].ToString(),ref strKeySql));
 }
 if (!string.IsNullOrEmpty(strCreateTableSql.ToString()))
 {
 if (strKeySql.Length > 0)
 {
 strKeySql.Remove(strKeySql.Length - 1, 1);
 strCreateTableSql.AppendFormat(" PRIMARY KEY CLUSTERED ( {0} )) ON [PRIMARY] ", strKeySql.ToString());
 strKeySql.Remove(strKeySql.Length - 1, 1);
 }
 else
 {
 if (strCreateTableSql.ToString().EndsWith(","))
 strCreateTableSql.Remove(strCreateTableSql.Length - 1, 1);
 strCreateTableSql.Append(" )");
 }
 dbHelper.ExecuteNonQuery(DataBaseName, strCreateTableSql.ToString(), null);
 dbHelper.ExecuteNonQuery(CommandType.Text, string.Format(" insert into {0}.dbo.{1} select * from {2}.dbo.{1} ", DataBaseName, tableName, ModelDataBaseName), null);
 }
 }
 #endregion

 #region 存储过程、视图、函数、触发器
 StringBuilder strSql = new StringBuilder();
 strSql.AppendFormat(" select name,type,definition from {0}.dbo.GetUserPV ",ModelDataBaseName);
 DataTable dt_GetUserPV = dbHelper.ExecuteQuery(CommandType.Text, strSql.ToString(), null).Tables[0];
 if (dt_GetUserPV.Rows.Count > 0)
 {
 StringBuilder strTest = new StringBuilder();
 foreach (DataRow dr in dt_GetUserPV.Rows)
 {
 dbHelper.ExecuteNonQuery(DataBaseName, string.Format("{0}", dr["definition"].ToString()), null);
 }
 
 }
 #endregion
 }