加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 站长学院 > MsSql教程 > 正文

SQLSERVER2000 用过程来模拟MDX分析报表的效果(1)

发布时间:2020-12-12 15:24:43 所属栏目:MsSql教程 来源:网络整理
导读:这个想法的产生比较特殊,当时我在某学会工作,我对数据仓库的学习也初见成效,也做了一两个基于数据仓库的产品,总觉得数据仓库部署比较麻烦,而我的客户仅仅是需要一张分析型的报表.他只要满足多维的旋转,聚合,产生一个层次性的报表就可以满足要求. ???? 基于这

这个想法的产生比较特殊,当时我在某学会工作,我对数据仓库的学习也初见成效,也做了一两个基于数据仓库的产品,总觉得数据仓库部署比较麻烦,而我的客户仅仅是需要一张分析型的报表.他只要满足多维的旋转,聚合,产生一个层次性的报表就可以满足要求.
???? 基于这种情况,我想:能不能在数据库下模拟一张这样的报表来满足用户的需要?
???? 因为写过仓库下的二个基于WEB的展示组件,显示一个MDX返回的CellSet,无非就是分解各轴中的Members的Caption,再取各单元格的属性作为显示格式等.思路并不复杂,不过,因为要设置合并,过程还是比较复杂的.
???? 那如果,我在数据库中用存储过程返回一个类CellSet的DataTable,那么,不也就可以实现了模拟的效果了吗?
???? 好了,闲话不说了.看正题吧.

第一部分:相关的存储过程
这个过程的目的就是生成一个类MDX的CellSet的结果.
要解释这个过程,先说CellSet的结构.我觉得因为你在了解了CellSet的结构后,理解这个过程会更简单,而且,我这个过程的思路本身就是从CellSet中来.

1.Cellset 对象
表示多维查询的结果。它是从立方或其它单元集中选出的单元的集合

Connection?????????????????? '//AdomdClient.AdomdConnection连接对象
?|
?|-CellSet?????????????????? '//查询结果集.
?? |
?? |-Cell??????????????????? '//结果集中的单元
?? |-Axes??????????????????? '//结果集的轴集合,
?? |-ProPerties????????????? '//提供者的 Cellset 信息,可用 Property 检索.

说明

使用直接、类似数组的访问来实现对 Cellset 中数据的检索。可以“深入”到特定的成员以获得该成员的数据。例如,下列代码将返回名为 cst 的单元集第一坐标轴第一位置中第一个成员的标题:
cst.Axes(0).Positions(0).Members(0).Caption

在单元集中没有当前单元的概念,而是使用 Item 方法从单元集中检索指定的 Cell 对象。Item 方法的参数确定检索哪个单元。可以指定单元的唯一序号值。也可通过使用单元集

每个轴上的位置号来检索单元。

使用 Cellset 对象的集合、方法和属性,可以:
通过设置它的 ActiveConnection 属性,使打开的连接与 Cellset 对象相关联。
使用 Open 方法执行并检索多维查询的结果。
使用 Item 方法从 Cellset 中检索 Cell。
使用 Axes 集合返回定义 Cellset 的 Axis 对象。
使用 FilterAxis 属性检索有关用于过滤 Cellset 中数据的维的信息。
使用 Source 属性返回或指定用于定义 Cellset 的查询。
使用 State 属性返回 Cellset 的当前状态(打开、关闭、正在执行或正在连接)。
使用 Close 方法关闭打开的 Cellset。
使用标准的 ADO Properties 集合检索特定提供者的 Cellset 信息。

下面的这个函数就是将一个CellSet转为一个DataTable,从源程序来,有删节.

??? ''' <summary>
??? ''' 将CellSet转为DataTable.
??? ''' </summary>
??? ''' <param name="CellSet">CellSet对象.</param>
??? ''' <returns>DataTable</returns>
??? ''' <remarks></remarks>
??? Private Function AdoMdCellSetToDataTable(ByVal CellSet As Microsoft.AnalysisServices.AdomdClient.CellSet) As DataTable

??????? Dim Dt As New DataTable
??????? Dim Dc As New DataColumn
??????? Dim Dr As DataRow = Nothing
??????? Dim I As Int32
??????? Dim ColName As String = ""
??????? Dim sC As Int32
??????? Dim sR As Int32 = 0
??????? Dim RowID As Int32 = 0
??????? Dim SDr As DataRow = Nothing

??????? sC = 1
??????? For Each M As Microsoft.AnalysisServices.AdomdClient.Member In CellSet.Axes(1).Positions(0).Members
??????????? sC += 1
??????????? Dc = New DataColumn()
??????????? Dc.ColumnName = Microsoft.VisualBasic.Space(sC) '//以空填充空白部分.
??????????? Dt.Columns.Add(Dc)
??????? Next

??????? '//生成数据列对象
??????? sR = 0
??????? Dim R,C As Int32
??????? Dim ColID As Int16 = 0
??????? Dim AxexCount_0 As Int32 = CellSet.Axes(0).Positions.Count
??????? Dim AxexCount_1 As Int32 = CellSet.Axes(1).Positions.Count
??????? Dim CName As String

??????? R = 0 : C = 0
??????? For Each P As Microsoft.AnalysisServices.AdomdClient.Position In CellSet.Axes(0).Positions '//分解0轴,Mdx中的 ON Columns 轴.
??????????? CName = ""
??????????? R = 0 : ColID += 1
??????????? For Each M As Microsoft.AnalysisServices.AdomdClient.Member In P.Members
??????????????? If R = 0 Then
??????????????????? CName = CName & "[" & Trim$(M.Caption) & "]"
??????????????? Else
??????????????????? CName = CName & ".[" & Trim$(M.Caption) & "]"
??????????????? End If

??????????????? R += 1
??????????? Next
??????????? Dc = New DataColumn()
??????????? Dc.ColumnName = CName
??????????? Dt.Columns.Add(Dc)
??????????? C += 1
??????? Next

??????? '//添加行数据
??????? Dim CellVal As String
??????? Dim Pos As Int32 = 0
??????? Dim Ts As String
??????? Dim Cid As Int32

??????? For Each py As Microsoft.AnalysisServices.AdomdClient.Position In CellSet.Axes(1).Positions? '//分解1轴,Mdx中的 ON Rows 轴
??????????? Dr = Dt.NewRow()
??????????? RowID += 1
??????????? I = 0
??????????? '//行方向的名称列.
??????????? For Each m As Microsoft.AnalysisServices.AdomdClient.Member In py.Members
??????????????? Ts = m.Caption
??????????????? Cid = I
??????????????? Dr(Cid) = Ts
??????????????? I += 1
??????????? Next

??????????? '//行数据
??????????? For X As Int32 = 1 To AxexCount_0
??????????????? CellVal = "" & CellSet(Pos).FormattedValue
??????????????? If CellVal = "1.#INF" OrElse CellVal = "-1.#IND" OrElse CellVal = "1#I.NF0" OrElse CellVal = "1#I.NF0%" Then CellVal = ""?
??????????????? Dr(Cid+X) = CellVal
??????????????? Pos += 1
??????????? Next
??????????? Dt.Rows.Add(Dr)
??????? Next
??????? Return Dt

??? End Function

?


效果:

?

?

观察上图,发现了什么,原来DataTable与CellSet是很象的.实质上,他们之间是可以通过前台的应用程序来转化,你如果将上图的DaTable 按 "].[" 来分解,按层合并相同项,DataTable也可以变成一个CellSet,有了这个思路,就可以写一个存储过程,将数据库中的数据按你的要求组织成要求的格式.将列的名称用自定义的分隔符分隔,就可以达到相同的目的了.
下面的SQL过程就实现了这个目的.自定义的分隔符是 "$@".

效果:

?

/***********************************************************
--调用例子
EXECUTE Prc_CorssReport_V2 N'test_data',
??? N'海关名称,洲名称,地区名称',
??? N'商品名称,年,月',
??? N'金额',' WHERE 海关编号 between ''01'' and ''02''?? and 时间编号 between 20070401 and 20070401? and 类编号=''10000002'''
***********************************************************/

CREATE PROC Prc_CorssReport_V2 (
------------------------------------------------------
--- 模拟 MDX V2.0 版.
---????????? MSTOP 2008/3/21
------------------------------------------------------
??? @nvr_TableName nvarchar(128),
??? @nvr_OnRows? nvarchar(1024),? --行列表
??? @nvr_OnColumns nvarchar(1024),? --列列表
??? @nvr_OnValue nvarchar(64),? --值字段
??? @nvr_Where? nvarchar(1024)='' --条件
) AS BEGIN

??? DECLARE @NVR_CMD NVARCHAR(1024)
??? DECLARE @NVR_Columns NVARCHAR(1024)
??? DECLARE @NVR_TmpTableName NVARCHAR(128)
??? DECLARE @NVR_NewColName varchar(16)
??? DECLARE @nvr_sOnRows NVARCHAR(1024)
??? DECLARE @nvr_OnRows_B NVARCHAR(1024)
??? DECLARE @nvr_OnColumns_B nvarchar(1024)
??? DECLARE @NVR_SQLCOM_00 NVARCHAR(4000)

??? SET @nvr_OnRows_B=N'[' + REPLACE(@nvr_OnRows,N',',N'],[') + N']'
??? SET @nvr_OnColumns_B=N'[' + REPLACE(@nvr_OnColumns,[') + N']'

??? SET @nvr_sOnRows=@nvr_OnRows
??? SET @NVR_NewColName=N'Val_' + LEFT(REPLACE(NEWID(),'-',''),6)
??? SET @NVR_TmpTableName=N'@TAB_TABLE'
??? --提取数据到表变量中.
??? SET @NVR_SQLCOM_00=N'DECLARE ' + @NVR_TmpTableName + N' TABLE ([' + REPLACE(@nvr_OnRows,N'] VARCHAR(128),[') + N'] VARCHAR(128),[' + @NVR_NewColName

+ N'] VARCHAR(128),[' + @nvr_OnValue + N'] FLOAT PRIMARY KEY? (' + @nvr_OnRows_B + N',[' + @NVR_NewColName + N']))'
??? --合并列的名称.分隔符为 $@,也可以指定其它的分隔符.
??? SET @NVR_Columns=N'RTRIM([' + REPLACE(@nvr_OnColumns,N']) + ''$@''+RTRIM([') + N'])+''$@'''
??? SET @NVR_SQLCOM_00=@NVR_SQLCOM_00 + CHAR(13) + N'INSERT INTO ' + @NVR_TmpTableName + N' SELECT ' +@nvr_OnRows_B + N',(' + @NVR_Columns + N') AS [' +

@NVR_NewColName + N'],SUM([' + @nvr_OnValue + N']) AS '
??????????? + @nvr_OnValue + N' FROM ' + @nvr_TableName
??????????? + @nvr_Where
??????????? + N' GROUP BY ' + @nvr_OnColumns_B?? + N',' +? @nvr_OnRows_B
??????????? + N' ORDER BY ' + @nvr_OnRows_B? + CHAR(13)

??? --因为动态生成的SQL语句很长,所以定义多个SQL变量.
??? DECLARE @NVR_XCOLNAME AS NVARCHAR(128)
??? DECLARE @NVR_SQL0 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL1 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL2 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL3 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL4 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL5 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL6 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL7 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL8 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL9 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL10 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL11 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL12 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL13 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL14 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL15 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL16 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL17 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL18 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL19 AS NVARCHAR(4000)
??? DECLARE @NVR_SQL20 AS NVARCHAR(4000)
??? DECLARE @INT_ID AS INT

??? SET @NVR_XCOLNAME=''
??? SELECT

@NVR_SQL0='',@INT_ID=0,@NVR_SQL0='',@NVR_SQL1='',@NVR_SQL2='',@NVR_SQL3='',@NVR_SQL4='',@NVR_SQL5='',@NVR_SQL6='',@NVR_SQL7='',@NVR_SQL8='',@NVR_SQL9='',
???????

@NVR_SQL10='',@NVR_SQL11='',@NVR_SQL12='',@NVR_SQL13='',@NVR_SQL14='',@NVR_SQL15='',@NVR_SQL16='',@NVR_SQL17='',@NVR_SQL18='',@NVR_SQL19='',@NVR_SQL20=''
?????
??? DECLARE @INT_I INT
??? DECLARE @NVR_FLDNAME NVARCHAR(4000)
???
??? SET @NVR_SQL0 = N' SELECT ' +? @nvr_OnRows_B
??? SET @NVR_CMD=N'DECLARE CORSS_CURSOR CURSOR FOR SELECT DISTINCT [' + @NVR_NewColName + N'] FROM (SELECT ' + @NVR_Columns + N' AS [' + @NVR_NewColName +

N'] FROM ' + @nvr_TableName + N' ' + @NVR_WHERE? + N' ) AS TIISHFURL ORDER BY [' + @NVR_NewColName + N'] FOR READ ONLY ' --生成游标
??? EXECUTE (@NVR_CMD)
??? OPEN CORSS_CURSOR
???
??? WHILE (1=1)? BEGIN
??????? FETCH NEXT FROM CORSS_CURSOR INTO @NVR_XCOLNAME? --遍历游标,将列头信息放入变量@NVR_XCOLNAME
??????? IF (@@FETCH_STATUS <>0) BREAK
???????
??????? SET @INT_ID=@INT_ID+1
??????? SET @NVR_XCOLNAME=REPLACE(@NVR_XCOLNAME,CHAR(39),CHAR(39)+CHAR(39))
???????
??????? ------------------------------------------------------------------------------
??????? IF @INT_ID <=20
??????????? SET @NVR_SQL1 = @NVR_SQL1 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF @INT_ID <=40
??????????? SET @NVR_SQL2 = @NVR_SQL2 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=60
??????????? SET @NVR_SQL3 = @NVR_SQL3 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=80
??????????? SET @NVR_SQL4 = @NVR_SQL4 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=100
??????????? SET @NVR_SQL5 = @NVR_SQL5 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=120
??????????? SET @NVR_SQL6 = @NVR_SQL6 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=140
??????????? SET @NVR_SQL7 = @NVR_SQL7 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=160
??????????? SET @NVR_SQL8 = @NVR_SQL8 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=180
??????????? SET @NVR_SQL9 = @NVR_SQL9 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END) AS

[' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=200
??????????? SET @NVR_SQL10 = @NVR_SQL10 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=220
??????????? SET @NVR_SQL11 = @NVR_SQL11 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=240
??????????? SET @NVR_SQL12 = @NVR_SQL12 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=260
??????????? SET @NVR_SQL13 = @NVR_SQL13 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=280
??????????? SET @NVR_SQL14 = @NVR_SQL14 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=300
??????????? SET @NVR_SQL15 = @NVR_SQL15 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=320
??????????? SET @NVR_SQL16 = @NVR_SQL16 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=340
??????????? SET @NVR_SQL17 = @NVR_SQL17 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=360
??????????? SET @NVR_SQL18 = @NVR_SQL18 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=380
??????????? SET @NVR_SQL19 = @NVR_SQL19 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??????? ELSE IF? @INT_ID <=400
??????????? SET @NVR_SQL20 = @NVR_SQL20 + N',SUM(CASE [' + @NVR_NewColName + N'] WHEN ''' + @NVR_XCOLNAME + N''' THEN [' + @nvr_OnValue + N'] ELSE NULL END)

AS [' + @NVR_XCOLNAME + N']' --构造查询
??? END -- WHILE (1 = 1)
??? Close CORSS_CURSOR
??? DEALLOCATE CORSS_CURSOR

??? EXECUTE ( @NVR_SQLCOM_00 + @NVR_SQL0 + @NVR_SQL1 + @NVR_SQL2? + @NVR_SQL3 + @NVR_SQL4 + @NVR_SQL5 + @NVR_SQL6 + @NVR_SQL7 + @NVR_SQL8 + @NVR_SQL9
???? + @NVR_SQL10 + @NVR_SQL11 + @NVR_SQL12? + @NVR_SQL13 + @NVR_SQL14 + @NVR_SQL15 + @NVR_SQL16 + @NVR_SQL17 + @NVR_SQL18 + @NVR_SQL19 + @NVR_SQL20
???? + N' FROM ' + @NVR_TmpTableName + N' GROUP BY ' + @nvr_OnRows ) -- 执行
??? RETURN 0 --释放游标,返回0表示成功

End

GO

?

来一张最终效果,否则你们没兴趣看了. 哈哈...

?

?

SQLSERVER2000 用过程来模拟MDX分析报表的效果(2)

?


本文来自CSDN博客,转载请标明出处:http://blog.csdn.net/mstop/archive/2008/10/11/3058767.aspx

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读