获取数据库结构的奥义......(无码，完全版，未删节)

看过《朝花夕拾:代码生成器的基础——获取数据源的架构信息》一文，感觉，方法正确但是点到即止，没有完全说透，所以来个补全版。经验之谈，欢迎拍砖

 

首先是获取的方法，没错，都是采用的Connection的GetSchema方法，但是这个方法对于不通的Connection来说，也就是底层连接的数据库有所不同的话，返回的DataTable其实是有区别的。有的是返回所有表和视图，有的是返回系统表+用户表+视图，注意，这个跟数据库有关，而不是XXXConnection，用OledbConnection连接Access和SqlServer返回的就是完全不同的。比如OledbConnection连接Access返回的DataTable里面第4列的值必须是“Table”的才是用户表，其余的都是系统表。如果用MysqlConnection连接Mysql的话第四列必须等于“BASE TABLE”的才是用户表。就算使用SqlClient去连接SqlServer2000和SqlServer2005也是有区别的。前者的第四列是“Base Table”而后者根本不需要判断，返回的都是用户表。

SqlServer2005：

 

SqlServer2005
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1 using (SqlConnection conn = new SqlConnection(ConnStr))
 2                {
 3                    if (conn.State == ConnectionState.Closed)
 4                    {
 5                        conn.Open();
 6                    }
 7                    DataTable sc = conn.GetSchema("Tables");
 8                    conn.Close();
 9                    foreach (DataRow row in sc.Rows)
10                    {
11                        Tables.Add(row[2].ToString());
12                    }
13                } 
14

 

               SqlServer2000：

 

SqlServer2000
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1 using (SqlConnection conn = new SqlConnection(ConnStr))
 2                {
 3                    if (conn.State == ConnectionState.Closed)
 4                    {
 5                        conn.Open();
 6                    }
 7                    DataTable sc = conn.GetSchema("Tables");
 8                    conn.Close();
 9                    foreach (DataRow row in sc.Rows)
10                    {
11                        if (row[3].ToString().Equals("BASE TABLE"))
12                        {
13                            Tables.Add(row[2].ToString());
14                        }
15                    }
16                } 
17

 

 

 

               MySql：

 

MySql
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1               using (MySqlConnection conn = new MySqlConnection(ConnStr))
 2                {
 3                    if (conn.State == ConnectionState.Closed)
 4                    {
 5                        conn.Open();
 6                    }
 7                    DataTable sc = conn.GetSchema("Tables");
 8                    conn.Close();
 9                    foreach (DataRow row in sc.Rows)
10                    {
11                        if (row[3].ToString().Equals("BASE TABLE"))
12                        {
13                            Tables.Add(row[2].ToString());
14                        }
15                    }
16                } 
17

 

 Access：

 

Access
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1using (OleDbConnection conn = new OleDbConnection(ConnStr))
 2{
 3    if (conn.State == ConnectionState.Closed)
 4    {
 5        conn.Open();
 6    } 
 7
 8    DataTable sc = conn.GetSchema("Tables");
 9    conn.Close();
10    foreach (DataRow row in sc.Rows)
11    {
12        if (row[3].ToString().Equals("TABLE"))
13        {
14            Tables.Add(row[2].ToString());
15        }
16    }
17} 
18
19

 

获取到表名后就可以通过表名去获取表的列信息，但是这个时候并不是单纯的说通过DataReader去GetSchama。这样子说纯粹是让人走弯路。

using (SqlDataReader rd = cmd.ExecuteReader(CommandBehavior.KeyInfo))
                {
                    Schema = rd.GetSchemaTable();
                    rd.Close();
                }

注意需要CommandBehavior.KeyInfo这个参数，加了这个参数获得的DataReader才能够通过GetSchemaTable()获得列信息。

同样的，通过不通的DataReader和不通的数据库，所得到的DataTable的数据还是有很多的差别，而且差别足够大到影响我们开发了，我不是单单获取一个列名就够了。

我们这里假设我们要获取的关键数据有

列名

类型（Varchar之类）

数据类型（程序里的类型，比如String）

是否主键

是否自动增加的列

我这里定义了一个类，也算是一个数据结构来获取数据表里的这些数据

 

ColumnProperty
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1public class ColumnProperty
 2{
 3    /**//// <summary>
 4    /// Column Name of DataTable
 5    /// 列名
 6    /// </summary>
 7    public string ColumnName { get; set; }
 8    /**//// <summary>
 9    /// Data Column's DataType
10    /// 用数值表示的数据列类型（其实也就是枚举的值）
11    /// </summary>
12    public int TypeNumber { get; set; }
13    /**//// <summary>
14    /// Property's Datatype in program
15    /// 实体字段的类型（string或者int之类）
16    /// </summary>
17    public string DataType { get; set; }
18    /**//// <summary>
19    /// if is Primary Key
20    /// 是否是主键
21    /// </summary>
22    public bool IsKey { get; set; }
23    /**//// <summary>
24    /// if is auto upgrede
25    /// 是否是自增字段（表示不能插入数据）
26    /// </summary>
27    public bool IsAuto { get; set; } 
28
29    /**//// <summary>
30    /// print schema result,this method used for test
31    /// </summary>
32    /// <returns>schema infomation</returns>
33} 
34
35

 

 

这里注意第二个field，这个属性是数据库里的类型，也就是用来给Parameter对象使用的，也就是数据定义在数据库里的类型。在程序里一般使用SqlDbType这个枚举来标示，其实这里我们用int来表示也就是说这个int的值和枚举的值是一一对应的。我们得到这个数值之后只需要

(SqlDbType)System.Enum.Parse(typeof(SqlDbType), “数值”)就能够得到对应的Type了。

 

下面的代码是不同数据库读取关键信息的不通点，注意看读取的列序号的不同

SqlServer2005：

 

SqlServer2005
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1foreach (DataRow row in Schema.Rows)
 2            {
 3                ppt = new ColumnProperty();
 4                ppt.ColumnName = row[0].ToString();
 5                ppt.TypeNumber = int.Parse(row[29].ToString());
 6                ppt.DataType = row[12].ToString();
 7                ppt.IsKey = bool.Parse(row[6].ToString().ToLower());
 8                ppt.IsAuto = bool.Parse(row[17].ToString().ToLower());
 9                Rs.Add(ppt);
10            } 

 

SqlServer2000：

 

SqlServer2000
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1foreach (DataRow row in Schema.Rows)
 2            {
 3                ppt = new ColumnProperty();
 4                ppt.ColumnName = row[0].ToString();
 5                ppt.TypeNumber = int.Parse(row[29].ToString());
 6                ppt.DataType = row[12].ToString();
 7                ppt.IsKey = bool.Parse(row[6].ToString().ToLower());
 8                ppt.IsAuto = bool.Parse(row[17].ToString().ToLower());
 9                Rs.Add(ppt);
10            } 
11
12

 

 

MySql：

 

Mysql
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1foreach (DataRow row in Schema.Rows)
 2            {
 3                ppt = new ColumnProperty();
 4                ppt.ColumnName =<s

分享到：

利用metaclass实现python的aop | Why .NET Sucks?

• 2008-10-14 13:10
• 浏览 539
• 评论(0)
• 查看更多