前言
项目中一般分测试环境（QAS），生产环境（PRD），当我们的项目经历了一次周期跨度较长的更新后，当我们发布到生产环境时，首要的任务是将新增的表，字段更新到生产数据库。很多时候，当我们发布更新的时候，已经很难记得做了哪些变更。
当然有的人会说，1.EF Code First 有history记录，这是一种办法，可靠么？不可靠。相信即便是用Code First，直接改数据库的肯定不止我一个。
2.查看实体类变更记录，这也是一个办法。那如果用的DB First的呢？当然也可以看，就是很麻烦。
3.开发过程中，对数据库的变更记下来。这么做过的肯定也不止我一个。手动狗头
。。。。。
中午的时候，就想着另外一个项目下个月要更新，改了N多的东西，到时候数据库咋更新呢。就想着写个工具比较两个版本数据库，表名称，字段，字段类型的区别。
说干就干（本来想着用EF，DBContext应该可以实现，无奈学艺不精，最终还是回到了ADO.Net）。
控制台应用程序，目前只能对比新增，修改（SQl Server）。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using Microsoft.EntityFrameworkCore;
namespace EFGetTable
{
class Program
{
static void Main(string[] args)
{
string prdconnectionstring = "Data Source=localhost;initial catalog=ttPRD;user id=sa;password=password;MultipleActiveResultSets=True";
var prd = GetTableNames(prdconnectionstring);
string qasconnectionstring = "Data Source=localhost;initial catalog=ttqas;user id=sa;password=password;MultipleActiveResultSets=True";
var qas = GetTableNames(qasconnectionstring);
CompareTable(prd, qas);
}
public static List<TableInfo> GetTableNames(string connectionstr)
{
var tableresult = new List<TableInfo>();
string sqlTableName = "Select * From Information_Schema.Tables";
using (SqlConnection connection = new SqlConnection(connectionstr))
{
using (SqlCommand cmd = new SqlCommand(sqlTableName, connection))
{
try
{
connection.Open();
SqlDataReader dr = cmd.ExecuteReader();//
while (dr.Read())
{
// 表名
TableInfo table = new TableInfo();
table.TableName = dr["Table_Name"].ToString();
table.columns.AddRange(GetColumnNamesByTable(dr["Table_Name"].ToString(), connection));
tableresult.Add(table);
}
connection.Close();
}
catch (System.Data.SqlClient.SqlException e)
{
Console.ForegroundColor = ConsoleColor.Red;
Console.Error.WriteLine(e.Message);
connection.Close();
}
}
return tableresult;
}
}
public static List<CloumnInfo> GetColumnNamesByTable(string tableName, SqlConnection connection)
{
var Columnresults = new List<CloumnInfo>();
string sqlcolum = $"Select * From Information_Schema.Columns t Where t.Table_Name =\'{tableName}\'";
using (SqlCommand cmd = new SqlCommand(sqlcolum, connection))
{
SqlDataReader dr = cmd.ExecuteReader();//
while (dr.Read())
{
// 表名
CloumnInfo column = new CloumnInfo();
column.CloumnName = dr["Column_name"].ToString();
column.DateType = dr["DATA_TYPE"].ToString() + dr["CHARACTER_MAXIMUM_LENGTH"].ToString();
Columnresults.Add(column);
}
return Columnresults;
}
}
public static void CompareTable(List<TableInfo> prd, List<TableInfo> qas)
{
foreach (var p in qas)
{
var tablequery = prd.AsQueryable().Where(t => t.TableName.Equals(p.TableName));
if (!tablequery.Any())
{
Console.WriteLine($"New Created Table {p.TableName}");
continue;
}
else
{
var querytable = tablequery.FirstOrDefault();
p.columns.ForEach(c =>
{
var Cloumnquery = querytable.columns.Select(cc => cc.CloumnName).Contains(c.CloumnName);
if (!Cloumnquery)
{
Console.WriteLine($"New add cloumn： {c.CloumnName} on Table {p.TableName}");
}
else
{
var querycloumn = querytable.columns.Where(qt => qt.CloumnName.Equals(c.CloumnName)).FirstOrDefault();
if (!querycloumn.DateType.Equals(c.DateType))
{
Console.WriteLine($"DateType Different: cloumn: {c.CloumnName} , {querycloumn.DateType}==>{c.DateType} on Table {p.TableName}");
}
}
});
}
}
}
}
public class TableInfo
{
public TableInfo()
{
columns = new List<CloumnInfo>();
}
public string TableName { get; set; }
public List<CloumnInfo> columns { get; set; }
}
public class CloumnInfo
{
public string CloumnName { get; set; }
public string DateType { get; set; }
}
}
|
测试结果
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对服务器之家的支持。
原文链接：https://www.cnblogs.com/kim-meng/p/11477474.html