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

2023-10-30 00:59

本文主要是介绍获取数据库结构的奥义......(无码,完全版,未删节),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

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

 

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

SqlServer2005:

 

ContractedBlock.gif ExpandedBlockStart.gif SqlServer2005
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 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.gif ExpandedBlockStart.gif SqlServer2000
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 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.gif ExpandedBlockStart.gif MySql
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 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.gif ExpandedBlockStart.gif Access
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 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.gif ExpandedBlockStart.gif ColumnProperty
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1public class ColumnProperty
 2ExpandedBlockStart.gifContractedBlock.gif{
 3ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// <summary>
 4    /// Column Name of DataTable
 5    /// 列名
 6    /// </summary>

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

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

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

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

27ExpandedSubBlockStart.gifContractedSubBlock.gif    public bool IsAuto getset; } 
28
29ExpandedSubBlockStart.gifContractedSubBlock.gif    /**//// <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:

 

ContractedBlock.gif ExpandedBlockStart.gif SqlServer2005
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 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.gif ExpandedBlockStart.gif SqlServer2000
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 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.gif ExpandedBlockStart.gif Mysql
<!--<br /><br />Code highlighting produced by Actipro CodeHighlighter (freeware)<br />http://www.CodeHighlighter.com/<br /><br />--> 1foreach (DataRow row in Schema.Rows)
 2ExpandedBlockStart.gifContractedBlock.gif            {
 3                ppt = new ColumnProperty();
 4                ppt.ColumnName =

这篇关于获取数据库结构的奥义......(无码,完全版,未删节)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/304573

相关文章

MySQL数据库双机热备的配置方法详解

《MySQL数据库双机热备的配置方法详解》在企业级应用中,数据库的高可用性和数据的安全性是至关重要的,MySQL作为最流行的开源关系型数据库管理系统之一,提供了多种方式来实现高可用性,其中双机热备(M... 目录1. 环境准备1.1 安装mysql1.2 配置MySQL1.2.1 主服务器配置1.2.2 从

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代

Python版本信息获取方法详解与实战

《Python版本信息获取方法详解与实战》在Python开发中,获取Python版本号是调试、兼容性检查和版本控制的重要基础操作,本文详细介绍了如何使用sys和platform模块获取Python的主... 目录1. python版本号获取基础2. 使用sys模块获取版本信息2.1 sys模块概述2.1.1

Redis中Set结构使用过程与原理说明

《Redis中Set结构使用过程与原理说明》本文解析了RedisSet数据结构,涵盖其基本操作(如添加、查找)、集合运算(交并差)、底层实现(intset与hashtable自动切换机制)、典型应用场... 目录开篇:从购物车到Redis Set一、Redis Set的基本操作1.1 编程常用命令1.2 集

Java发送SNMP至交换机获取交换机状态实现方式

《Java发送SNMP至交换机获取交换机状态实现方式》文章介绍使用SNMP4J库(2.7.0)通过RCF1213-MIB协议获取交换机单/多路状态,需开启SNMP支持,重点对比SNMPv1、v2c、v... 目录交换机协议SNMP库获取交换机单路状态获取交换机多路状态总结交换机协议这里使用的交换机协议为常

MyBatis/MyBatis-Plus同事务循环调用存储过程获取主键重复问题分析及解决

《MyBatis/MyBatis-Plus同事务循环调用存储过程获取主键重复问题分析及解决》MyBatis默认开启一级缓存,同一事务中循环调用查询方法时会重复使用缓存数据,导致获取的序列主键值均为1,... 目录问题原因解决办法如果是存储过程总结问题myBATis有如下代码获取序列作为主键IdMappe

C#使用iText获取PDF的trailer数据的代码示例

《C#使用iText获取PDF的trailer数据的代码示例》开发程序debug的时候,看到了PDF有个trailer数据,挺有意思,于是考虑用代码把它读出来,那么就用到我们常用的iText框架了,所... 目录引言iText 核心概念C# 代码示例步骤 1: 确保已安装 iText步骤 2: C# 代码程

使用Node.js和PostgreSQL构建数据库应用

《使用Node.js和PostgreSQL构建数据库应用》PostgreSQL是一个功能强大的开源关系型数据库,而Node.js是构建高效网络应用的理想平台,结合这两个技术,我们可以创建出色的数据驱动... 目录初始化项目与安装依赖建立数据库连接执行CRUD操作查询数据插入数据更新数据删除数据完整示例与最佳

Oracle数据库在windows系统上重启步骤

《Oracle数据库在windows系统上重启步骤》有时候在服务中重启了oracle之后,数据库并不能正常访问,下面:本文主要介绍Oracle数据库在windows系统上重启的相关资料,文中通过代... oracle数据库在Windows上重启的方法我这里是使用oracle自带的sqlplus工具实现的方

MySQL批量替换数据库字符集的实用方法(附详细代码)

《MySQL批量替换数据库字符集的实用方法(附详细代码)》当需要修改数据库编码和字符集时,通常需要对其下属的所有表及表中所有字段进行修改,下面:本文主要介绍MySQL批量替换数据库字符集的实用方法... 目录前言为什么要批量修改字符集?整体脚本脚本逻辑解析1. 设置目标参数2. 生成修改表默认字符集的语句3