连锁创建分店数据库方法(二)
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
}