热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

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

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

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

 

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

SqlServer2005:

 

ContractedBlock.gifExpandedBlockStart.gifSqlServer2005
 1 using (SqlConnection conn = new SqlConnection(ConnStr))
 2ExpandedBlockStart.gifContractedBlock.gif                {
 3                    if (conn.State == ConnectionState.Closed)
 4ExpandedSubBlockStart.gifContractedSubBlock.gif                    {
 5                        conn.Open();
 6                    }

 7                    DataTable sc = conn.GetSchema("Tables");
 8                    conn.Close();
 9                    foreach (DataRow row in sc.Rows)
10ExpandedSubBlockStart.gifContractedSubBlock.gif                    {
11                        Tables.Add(row[2].ToString());
12                    }

13                }
 
14

 

               SqlServer2000:

 

ContractedBlock.gifExpandedBlockStart.gifSqlServer2000
 1 using (SqlConnection conn = new SqlConnection(ConnStr))
 2ExpandedBlockStart.gifContractedBlock.gif                {
 3                    if (conn.State == ConnectionState.Closed)
 4ExpandedSubBlockStart.gifContractedSubBlock.gif                    {
 5                        conn.Open();
 6                    }
 7                    DataTable sc = conn.GetSchema("Tables");
 8                    conn.Close();
 9                    foreach (DataRow row in sc.Rows)
10ExpandedSubBlockStart.gifContractedSubBlock.gif                    {
11                        if (row[3].ToString().Equals("BASE TABLE"))
12ExpandedSubBlockStart.gifContractedSubBlock.gif                        {
13                            Tables.Add(row[2].ToString());
14                        }

15                    }

16                }
 
17

 

 

 

               MySql:

 

ContractedBlock.gifExpandedBlockStart.gifMySql
 1               using (MySqlConnection conn = new MySqlConnection(ConnStr))
 2ExpandedBlockStart.gifContractedBlock.gif                {
 3                    if (conn.State == ConnectionState.Closed)
 4ExpandedSubBlockStart.gifContractedSubBlock.gif                    {
 5                        conn.Open();
 6                    }

 7                    DataTable sc = conn.GetSchema("Tables");
 8                    conn.Close();
 9                    foreach (DataRow row in sc.Rows)
10ExpandedSubBlockStart.gifContractedSubBlock.gif                    {
11                        if (row[3].ToString().Equals("BASE TABLE"))
12ExpandedSubBlockStart.gifContractedSubBlock.gif                        {
13                            Tables.Add(row[2].ToString());
14                        }

15                    }

16                }
 
17

 

 Access:

 

ContractedBlock.gifExpandedBlockStart.gifAccess
 1using (OleDbConnection conn = new OleDbConnection(ConnStr))
 2ExpandedBlockStart.gifContractedBlock.gif{
 3    if (conn.State == ConnectionState.Closed)
 4ExpandedSubBlockStart.gifContractedSubBlock.gif    {
 5        conn.Open();
 6    }
 
 7
 8    DataTable sc = conn.GetSchema("Tables");
 9    conn.Close();
10    foreach (DataRow row in sc.Rows)
11ExpandedSubBlockStart.gifContractedSubBlock.gif    {
12        if (row[3].ToString().Equals("TABLE"))
13ExpandedSubBlockStart.gifContractedSubBlock.gif        {
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)

是否主键

是否自动增加的列

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

 

ContractedBlock.gifExpandedBlockStart.gifColumnProperty
 1public class ColumnProperty
 2ExpandedBlockStart.gifContractedBlock.gif{
 3ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// 
 4    /// Column Name of DataTable
 5    /// 列名
 6    /// 

 7ExpandedSubBlockStart.gifContractedSubBlock.gif    public string ColumnName getset; }
 8ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// 
 9    /// Data Column's DataType
10    /// 用数值表示的数据列类型(其实也就是枚举的值)
11    /// 

12ExpandedSubBlockStart.gifContractedSubBlock.gif    public int TypeNumber getset; }
13ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// 
14    /// Property's Datatype in program
15    /// 实体字段的类型(string或者int之类)
16    /// 

17ExpandedSubBlockStart.gifContractedSubBlock.gif    public string DataType getset; }
18ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// 
19    /// if is Primary Key
20    /// 是否是主键
21    /// 

22ExpandedSubBlockStart.gifContractedSubBlock.gif    public bool IsKey getset; }
23ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// 
24    /// if is auto upgrede
25    /// 是否是自增字段(表示不能插入数据)
26    /// 

27ExpandedSubBlockStart.gifContractedSubBlock.gif    public bool IsAuto getset; } 
28
29ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// 
30    /// print schema result,this method used for test
31    /// 

32    /// schema infomation

33}
 
34
35

 

 

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

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

 

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

SqlServer2005:

 

ContractedBlock.gifExpandedBlockStart.gifSqlServer2005
 1foreach (DataRow row in Schema.Rows)
 2ExpandedBlockStart.gifContractedBlock.gif            {
 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:

 

ContractedBlock.gifExpandedBlockStart.gifSqlServer2000
 1foreach (DataRow row in Schema.Rows)
 2ExpandedBlockStart.gifContractedBlock.gif            {
 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:

 

ContractedBlock.gifExpandedBlockStart.gifMysql
 1foreach (DataRow row in Schema.Rows)
 2ExpandedBlockStart.gifContractedBlock.gif            {
 3                ppt = new ColumnProperty();
 4                ppt.ColumnName = row[0].ToString();
 5                ppt.TypeNumber = int.Parse(row[13].ToString());
 6                ppt.DataType = row[11].ToString();
 7                ppt.IsKey = bool.Parse(row[6].ToString().ToLower());
 8                ppt.IsAuto = bool.Parse(row[17].ToString().ToLower());
 9                Rs.Add(ppt);
10            } 

 

Access:

 

ContractedBlock.gifExpandedBlockStart.gifAccess
 1foreach (DataRow row in Schema.Rows)
 2ExpandedBlockStart.gifContractedBlock.gif            {
 3                ppt = new ColumnProperty();
 4                ppt.ColumnName = row[0].ToString();
 5                ppt.TypeNumber = int.Parse(row[6].ToString());
 6                ppt.DataType = row[5].ToString();
 7                ppt.IsKey = bool.Parse(row[12].ToString().ToLower());
 8                ppt.IsAuto = bool.Parse(row[13].ToString().ToLower());
 9                Rs.Add(ppt);
10            }
 
11
12

 



推荐阅读
  • MySQL语句大全:创建、授权、查询、修改等【MySQL】的使用方法详解
    本文详细介绍了MySQL语句的使用方法,包括创建用户、授权、查询、修改等操作。通过连接MySQL数据库,可以使用命令创建用户,并指定该用户在哪个主机上可以登录。同时,还可以设置用户的登录密码。通过本文,您可以全面了解MySQL语句的使用方法。 ... [详细]
  • 本文介绍了设计师伊振华受邀参与沈阳市智慧城市运行管理中心项目的整体设计,并以数字赋能和创新驱动高质量发展的理念,建设了集成、智慧、高效的一体化城市综合管理平台,促进了城市的数字化转型。该中心被称为当代城市的智能心脏,为沈阳市的智慧城市建设做出了重要贡献。 ... [详细]
  • 如何使用Java获取服务器硬件信息和磁盘负载率
    本文介绍了使用Java编程语言获取服务器硬件信息和磁盘负载率的方法。首先在远程服务器上搭建一个支持服务端语言的HTTP服务,并获取服务器的磁盘信息,并将结果输出。然后在本地使用JS编写一个AJAX脚本,远程请求服务端的程序,得到结果并展示给用户。其中还介绍了如何提取硬盘序列号的方法。 ... [详细]
  • 本文介绍了OC学习笔记中的@property和@synthesize,包括属性的定义和合成的使用方法。通过示例代码详细讲解了@property和@synthesize的作用和用法。 ... [详细]
  • eclipse学习(第三章:ssh中的Hibernate)——11.Hibernate的缓存(2级缓存,get和load)
    本文介绍了eclipse学习中的第三章内容,主要讲解了ssh中的Hibernate的缓存,包括2级缓存和get方法、load方法的区别。文章还涉及了项目实践和相关知识点的讲解。 ... [详细]
  • Python正则表达式学习记录及常用方法
    本文记录了学习Python正则表达式的过程,介绍了re模块的常用方法re.search,并解释了rawstring的作用。正则表达式是一种方便检查字符串匹配模式的工具,通过本文的学习可以掌握Python中使用正则表达式的基本方法。 ... [详细]
  • 《数据结构》学习笔记3——串匹配算法性能评估
    本文主要讨论串匹配算法的性能评估,包括模式匹配、字符种类数量、算法复杂度等内容。通过借助C++中的头文件和库,可以实现对串的匹配操作。其中蛮力算法的复杂度为O(m*n),通过随机取出长度为m的子串作为模式P,在文本T中进行匹配,统计平均复杂度。对于成功和失败的匹配分别进行测试,分析其平均复杂度。详情请参考相关学习资源。 ... [详细]
  • 自动轮播,反转播放的ViewPagerAdapter的使用方法和效果展示
    本文介绍了如何使用自动轮播、反转播放的ViewPagerAdapter,并展示了其效果。该ViewPagerAdapter支持无限循环、触摸暂停、切换缩放等功能。同时提供了使用GIF.gif的示例和github地址。通过LoopFragmentPagerAdapter类的getActualCount、getActualItem和getActualPagerTitle方法可以实现自定义的循环效果和标题展示。 ... [详细]
  • 高质量SQL书写的30条建议
    本文提供了30条关于优化SQL的建议,包括避免使用select *,使用具体字段,以及使用limit 1等。这些建议是基于实际开发经验总结出来的,旨在帮助读者优化SQL查询。 ... [详细]
  • 本文介绍了南邮ctf-web的writeup,包括签到题和md5 collision。在CTF比赛和渗透测试中,可以通过查看源代码、代码注释、页面隐藏元素、超链接和HTTP响应头部来寻找flag或提示信息。利用PHP弱类型,可以发现md5('QNKCDZO')='0e830400451993494058024219903391'和md5('240610708')='0e462097431906509019562988736854'。 ... [详细]
  • 本文介绍了如何使用C#制作Java+Mysql+Tomcat环境安装程序,实现一键式安装。通过将JDK、Mysql、Tomcat三者制作成一个安装包,解决了客户在安装软件时的复杂配置和繁琐问题,便于管理软件版本和系统集成。具体步骤包括配置JDK环境变量和安装Mysql服务,其中使用了MySQL Server 5.5社区版和my.ini文件。安装方法为通过命令行将目录转到mysql的bin目录下,执行mysqld --install MySQL5命令。 ... [详细]
  • 本文详细介绍了如何使用MySQL来显示SQL语句的执行时间,并通过MySQL Query Profiler获取CPU和内存使用量以及系统锁和表锁的时间。同时介绍了效能分析的三种方法:瓶颈分析、工作负载分析和基于比率的分析。 ... [详细]
  • 如何查询zone下的表的信息
    本文介绍了如何通过TcaplusDB知识库查询zone下的表的信息。包括请求地址、GET请求参数说明、返回参数说明等内容。通过curl方法发起请求,并提供了请求示例。 ... [详细]
  • 本文讨论了如何使用Web.Config进行自定义配置节的配置转换。作者提到,他将msbuild设置为详细模式,但转换却忽略了带有替换转换的自定义部分的存在。 ... [详细]
  • 本文主要复习了数据库的一些知识点,包括环境变量设置、表之间的引用关系等。同时介绍了一些常用的数据库命令及其使用方法,如创建数据库、查看已存在的数据库、切换数据库、创建表等操作。通过本文的学习,可以加深对数据库的理解和应用能力。 ... [详细]
author-avatar
yangaien
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有