基本信息
源码名称:EF Code First 给SQL Server中的表/字段加上说明描述
源码大小:4.33KB
文件格式:.zip
开发语言:C#
更新时间:2018-08-15
友情提示:(无需注册或充值,赞助后即可获取资源下载链接)
嘿,亲!知识可是无价之宝呢,但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下,绝对物超所值哦!如有下载和支付问题,请联系我们QQ(微信同号):78630559
本次赞助数额为: 2 元×
微信扫码支付:2 元
×
请留下您的邮箱,我们将在2小时内将文件发到您的邮箱
源码介绍
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.Core.Objects;
using System.Data.Entity.Infrastructure;
using System.Data.SqlClient;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
namespace Models
{
public class DBDescriptionUpdater<TContext> where TContext : DbContext
{
private TContext context;
private DbTransaction transaction;
public DBDescriptionUpdater(TContext context)
{
this.context = context;
}
public void UpdateDatabaseDescriptions()
{
var contextType = typeof(TContext);
var props = contextType.GetProperties(BindingFlags.Instance | BindingFlags.Public);
transaction = null;
try
{
context.Database.Connection.Open();
transaction = context.Database.Connection.BeginTransaction();
foreach (var prop in props)
{
if (prop.PropertyType.InheritsOrImplements((typeof(DbSet<>))))
{
var tableType = prop.PropertyType.GetGenericArguments()[0];
SetTableDescriptions(tableType);
}
}
transaction.Commit();
}
catch
{
if (transaction != null)
transaction.Rollback();
throw;
}
finally
{
context.Database.Connection.Close();
}
}
private void SetTableDescriptions(Type tableType)
{
string fullTableName = context.GetTableName(tableType);
Regex regex = new Regex(@"(\[\w \]\.)?\[(?<table>.*)\]");
Match match = regex.Match(fullTableName);
var tableName = match.Success ? match.Groups["table"].Value : fullTableName;
var tableAttrs = tableType.GetCustomAttributes(typeof(TableAttribute), false);
if (tableAttrs.Length > 0)
tableName = ((TableAttribute)tableAttrs[0]).Name;
var dbTableDescattr = tableType.GetCustomAttribute(typeof(DBDescriptionAttribute), false);
string tableComment = ((DBDescriptionAttribute)dbTableDescattr).Description;
if (!string.IsNullOrEmpty(tableComment))
SetDBDescription(tableName, null, tableComment);
foreach (var prop in tableType.GetProperties(BindingFlags.Public | BindingFlags.Instance))
{
var dbDescAttr = prop.GetCustomAttribute(typeof(DBDescriptionAttribute), false);
if (dbDescAttr == null) continue;
var columnNameAttr = prop.GetCustomAttribute(typeof(ColumnAttribute), false);
if (columnNameAttr != null)
{
var columnName = ((ColumnAttribute)columnNameAttr).Name;
SetDBDescription(tableName, string.IsNullOrEmpty(columnName) ? prop.Name : columnName,
((DBDescriptionAttribute)dbDescAttr).Description);
}
else
{
SetDBDescription(tableName, prop.Name, ((DBDescriptionAttribute)dbDescAttr).Description);
}
}
}
private void SetDBDescription(string tableName, string columnName, string description)
{
string desc = string.Empty;
if (string.IsNullOrEmpty(columnName))
desc = "select [value] from fn_listextendedproperty('MS_Description','schema','dbo','table',N'" tableName "',null,null);";
else
desc = "select [value] from fn_listextendedproperty('MS_Description','schema','dbo','table',N'" tableName "','column',null) where objname = N'" columnName "';";
var prevDesc = (string)RunSqlScalar(desc);
var parameters = new List<SqlParameter>
{
new SqlParameter("@table", tableName),
new SqlParameter("@desc", description)
};
string funcName = "sp_addextendedproperty";
if (!string.IsNullOrEmpty(prevDesc))
funcName = "sp_updateextendedproperty";
string query = @"EXEC " funcName @" N'MS_Description', @desc, N'Schema', 'dbo', N'Table', @table";
if (!string.IsNullOrEmpty(columnName))
{
query = ", N'Column', @column";
parameters.Add(new SqlParameter("@column", columnName));
}
RunSql(query, parameters.ToArray());
}
DbCommand CreateCommand(string cmdText, params SqlParameter[] parameters)
{
var cmd = context.Database.Connection.CreateCommand();
cmd.CommandText = cmdText;
cmd.Transaction = transaction;
foreach (var p in parameters)
cmd.Parameters.Add(p);
return cmd;
}
void RunSql(string cmdText, params SqlParameter[] parameters)
{
var cmd = CreateCommand(cmdText, parameters);
cmd.ExecuteNonQuery();
}
object RunSqlScalar(string cmdText, params SqlParameter[] parameters)
{
var cmd = CreateCommand(cmdText, parameters);
return cmd.ExecuteScalar();
}
}
}