我們都知道,在紫金橋軟件中可以通過腳本或報(bào)表來訪問關(guān)系庫(kù)系統(tǒng)。我們通常的訪問方式大概如下(以報(bào)表訪問關(guān)系庫(kù)為例):
- 建立報(bào)表關(guān)系數(shù)據(jù)源點(diǎn),配置關(guān)系數(shù)據(jù)源點(diǎn)連接的數(shù)據(jù)庫(kù)用戶名和密碼等屬性。
- 繪制報(bào)表,在報(bào)表的關(guān)系數(shù)據(jù)庫(kù)連接中指明第一步建立的報(bào)表關(guān)系數(shù)據(jù)源點(diǎn)。
- 在報(bào)表上寫對(duì)關(guān)系庫(kù)操作的命令,比如SELECT命令。
- 在報(bào)表中對(duì)關(guān)系庫(kù)返回的結(jié)果進(jìn)行處理,最簡(jiǎn)單的是報(bào)表自動(dòng)顯示結(jié)果。
這里第3步的SELECT命令中可以訪問SQL中的表或視圖。另外也可以使用存儲(chǔ)過程,比如:
#R.SqlExeCmdNoRet("EXEC DOTRANCDATA");
這里的EXEC DOTRANCDATA表示執(zhí)行DOTRANCDATA這個(gè)存儲(chǔ)過程。
下面我們通過一個(gè)簡(jiǎn)單的例子來說明一下存儲(chǔ)過程的用法。
比如我們需要做一個(gè)產(chǎn)品出入庫(kù)的項(xiàng)目,產(chǎn)品在某一個(gè)地方通過驅(qū)動(dòng)或條碼設(shè)備自動(dòng)進(jìn)行入庫(kù)操作,當(dāng)數(shù)據(jù)進(jìn)入關(guān)系庫(kù)之后,可以通過關(guān)系庫(kù)的各種統(tǒng)計(jì)分析查詢功能來對(duì)產(chǎn)品進(jìn)行統(tǒng)計(jì)和檢索,由于需要在多個(gè)地方進(jìn)行檢索,所以SQL數(shù)據(jù)庫(kù)放在遠(yuǎn)端網(wǎng)絡(luò)的一個(gè)服務(wù)器上。
但是這里存在這么一個(gè)問題,由于網(wǎng)絡(luò)有可能會(huì)偶爾出現(xiàn)故障,雖然在故障情況下暫時(shí)不能查詢是可以理解的,但是我們不能允許在網(wǎng)絡(luò)出現(xiàn)故障的情況下,產(chǎn)品不能入庫(kù)。
這種問題可以這么解決,在本地關(guān)系庫(kù)中建立一個(gè)緩沖表,數(shù)據(jù)先插入本地的緩沖表中,然后通過存儲(chǔ)過程,把本地的緩沖表中的數(shù)據(jù)移動(dòng)到遠(yuǎn)端的產(chǎn)品庫(kù)中。在本地的任何檢索和查詢都是針對(duì)的遠(yuǎn)端的產(chǎn)品庫(kù)來進(jìn)行。這樣當(dāng)網(wǎng)絡(luò)中斷的時(shí)候,數(shù)據(jù)就可以先緩沖到本地,此時(shí)產(chǎn)品的入庫(kù)工作仍然可以順利的進(jìn)行,只不過本地的數(shù)據(jù)無法自動(dòng)的移動(dòng)到遠(yuǎn)端,此時(shí)在遠(yuǎn)端的數(shù)據(jù)庫(kù)中是無法檢索到這些入庫(kù)的產(chǎn)品的。當(dāng)網(wǎng)絡(luò)恢復(fù)之后,由存儲(chǔ)過程自動(dòng)的把數(shù)據(jù)移動(dòng)到遠(yuǎn)端數(shù)據(jù)庫(kù)中,此時(shí)在遠(yuǎn)端數(shù)據(jù)庫(kù)中就可以檢索到這些產(chǎn)品了。
下面我們舉一個(gè)簡(jiǎn)單的例子,為了簡(jiǎn)化說明我們的兩個(gè)表都在本地?cái)?shù)據(jù)庫(kù)中,首先數(shù)據(jù)插入其中的一個(gè)表中,然后在使用存儲(chǔ)過程移動(dòng)到另外一個(gè)表。對(duì)于跨數(shù)據(jù)庫(kù)的表,處理方式一樣,只需要稍微做些調(diào)整就行了。
首先我們?cè)赟QL中建立兩個(gè)表,名為“測(cè)試數(shù)據(jù)源”和“測(cè)試目標(biāo)”,如下圖所示:

在測(cè)試數(shù)據(jù)源和測(cè)試目標(biāo)中建立結(jié)構(gòu)相同的兩個(gè)數(shù)據(jù)表,如下圖所示:

這里是一個(gè)簡(jiǎn)單的人員入庫(kù)表,表明為User,有三個(gè)字段,第一個(gè)是自動(dòng)增長(zhǎng)的ID,第二個(gè)是人名,第三個(gè)年齡。
我們?cè)谧辖饦蛑袆?chuàng)建一個(gè)關(guān)系數(shù)據(jù)源點(diǎn),讓該點(diǎn)連接“測(cè)試數(shù)據(jù)源”數(shù)據(jù)庫(kù),如下圖所示:

在紫金橋中創(chuàng)建一個(gè)窗口,并且創(chuàng)建一個(gè)報(bào)表,給報(bào)表關(guān)聯(lián)剛剛建立的報(bào)表關(guān)系數(shù)據(jù)源點(diǎn)。
在報(bào)表上允許用戶輸入姓名和年齡,如下圖所示:

給姓名和年齡的輸入位置設(shè)置相應(yīng)的輸入方式,給提交按鈕關(guān)聯(lián)如下的腳本:
SqlExeCmdNoRet("INSERT INTO [User](Name, [Year]) VALUES ('"+Txt(1,1)+"', "+Txt(2,1)+")");
即可把人員姓名和年齡插入數(shù)據(jù)庫(kù)中。
下面我們通過存儲(chǔ)過程來把數(shù)據(jù)從“測(cè)試數(shù)據(jù)源”庫(kù)移動(dòng)到“測(cè)試目標(biāo)”庫(kù)中。
在“測(cè)試數(shù)據(jù)源”庫(kù)中創(chuàng)建一個(gè)存儲(chǔ)過程,如下圖所示:

點(diǎn)擊確定即可創(chuàng)建存儲(chǔ)過程。
打開SQL查詢分析器,選中相應(yīng)的存儲(chǔ)過程,右鍵菜單選擇編輯功能,如下圖所示:

在此處輸入如下的代碼:
SET QUOTED_IDENTIFIER ON
GO
SET ANSI_NULLS OFF
GO
ALTERPROCEDURE MoveDataAS
DECLARE @strVARCHAR(1000)
DECLARE @SqlstrVARCHAR(1000)
SET @str = ''
SELECT @str=@str+','+syscolumns.[name] FROM syscolumns WHERE syscolumns.id=object_id('User') and syscolumns.[name]<>'ID'
SET @str = stuff(@str,1,1,'')
SET @str = 'INSERT INTO 測(cè)試目標(biāo).dbo.[User](' + @str + ') SELECT ' + @str + ' FROM 測(cè)試數(shù)據(jù)源.dbo.[User]'
DECLARE Ptr CURSOR
FOR
SELECT ID FROM 測(cè)試數(shù)據(jù)源.dbo.[User]
OPEN Ptr
DECLARE @ID INT
FETCH NEXT FROM Ptr INTO @ID
WHILE (@@FETCH_STATUS <> -1)
BEGIN
IF (@@FETCH_STATUS <> -2)
BEGIN
SET @Sqlstr = @str + ' WHERE ID=' + CONVERT(varchar, @ID)
EXEC(@Sqlstr)
DELETE FROM 測(cè)試數(shù)據(jù)源.dbo.[User] WHERE ID = @ID
END
FETCH NEXT FROM Ptr INTO @ID
END
CLOSE Ptr
DEALLOCATE Ptr
GO
SET QUOTED_IDENTIFIER OFF
GO
SET ANSI_NULLS ON
GO
其中前面和后面5行代碼,是固定的,功能主要是更改存儲(chǔ)過程的內(nèi)容。
中間的內(nèi)容是移動(dòng)數(shù)據(jù),這里我們不能簡(jiǎn)單的這樣寫:
INSERT INTO 測(cè)試目標(biāo).dbo.[User] SELECT * FROM 測(cè)試數(shù)據(jù)源.dbo.[User]
因?yàn),兩個(gè)表中都有自動(dòng)增長(zhǎng)的字段ID,如果復(fù)制所有的內(nèi)容,也會(huì)導(dǎo)致復(fù)制ID字段的內(nèi)容,而這會(huì)打亂系統(tǒng)自動(dòng)增長(zhǎng)的規(guī)律,可能會(huì)導(dǎo)致執(zhí)行失敗。
DECLARE @strVARCHAR(1000)
DECLARE @SqlstrVARCHAR(1000)
SET @str = ''
SELECT @str=@str+','+syscolumns.[name] FROM syscolumns WHERE syscolumns.id=object_id('User') and syscolumns.[name]<>'ID'
SET @str = stuff(@str,1,1,'')
這一段代碼,查詢User表中的所有名稱不為ID的字段的名稱,并用逗號(hào)分隔。
SET @str = stuff(@str,1,1,'')
這一句代碼的功能是去除開始的逗號(hào)。
SET @str = 'INSERT INTO 測(cè)試目標(biāo).dbo.[User](' + @str + ') SELECT ' + @str + ' FROM 測(cè)試數(shù)據(jù)源.dbo.[User]'
這一句代碼生成復(fù)制數(shù)據(jù)的命令。
DECLARE Ptr CURSOR
FOR
SELECT ID FROM 測(cè)試數(shù)據(jù)源.dbo.[User]
OPEN Ptr
DECLARE @ID INT
FETCH NEXT FROM Ptr INTO @ID
WHILE (@@FETCH_STATUS <> -1)
BEGIN
IF (@@FETCH_STATUS <> -2)
BEGIN
SET @Sqlstr = @str + ' WHERE ID=' + CONVERT(varchar, @ID)
EXEC(@Sqlstr)
DELETE FROM 測(cè)試數(shù)據(jù)源.dbo.[User] WHERE ID = @ID
END
FETCH NEXT FROM Ptr INTO @ID
END
CLOSE Ptr
DEALLOCATE Ptr
這一段代碼,使用了多個(gè)游標(biāo),逐行的復(fù)制數(shù)據(jù)和刪除數(shù)據(jù),以實(shí)現(xiàn)移動(dòng)數(shù)據(jù)的目的。
這里之所以采取一行一行的移動(dòng)數(shù)據(jù),主要是為了防止,在移動(dòng)數(shù)據(jù)的過程中,又有了新的人員入庫(kù),插入了新的記錄。一行一行的移動(dòng)可以使得復(fù)制數(shù)據(jù)和刪除數(shù)據(jù)可以一一對(duì)應(yīng)。
最后可以把此存儲(chǔ)過程放到作業(yè)中,使得它可以被周期運(yùn)行,就可以實(shí)現(xiàn)自動(dòng)的數(shù)據(jù)移動(dòng)了。
|