websphere message broker数据库访问

  • 格式:doc
  • 大小:3.81 MB
  • 文档页数:4

MB中Compute节点是通过ODBC的方式访问数据库,所以需要进行几个准备步骤
1.配置ODBC
2.设置Broker访问数据库的账号密码
3.编写ESQL代码访问数据库

1. 配置ODBC连接。
a) 用wbiadmin登录系统
b) 用以下命令查看当前设置的ODBC配置文件位置:
echo $ODBCINI
默认位置为/var/mqsi/odbc/.odbc.ini,
c) vi 打开.odbc.ini文件,为WBRKDB数据库配置ODBC数据源。例如修改为
如下设置:

;##########################################
;###### List of data sources stanza #######
;##########################################
[ODBC Data Sources]
DB2DB=IBM DB2 ODBC Driver
ORACLEDB=DataDirect 6.0 Oracle Wire Protocol
ORACLERACDB=DataDirect 6.0 Oracle Wire Protocol (Real
Application Clusters)

SYBASEDB=DataDirect 6.0 Sybase Wire Protocol
SYBASEDBUTF8=DataDirect 6.0 Sybase UTF8 Wire Protocol
SQLSERVERDB=DataDirect 6.0 SQL Server Wire Protocol
INFORMIXDB=IBM Informix ODBC Driver

;# Oracle stanza
[ORACLEDB]
Driver=directory>/ODBC/V6.0/lib/UKora24.so
Description=DataDirect 6.0 Oracle Wire Protocol
HostName=
PortNumber=
SID=
CatalogOptions=0
EnableStaticCursorsForLongData=0
ApplicationUsingThreads=1
EnableDescribeParam=1
OptimizePrepare=1
WorkArounds=536870912
ProcedureRetResults=1
ColumnSizeAsCharacter=1

;##########################################
;###### Mandatory information stanza ######
;##########################################

[ODBC]
;# To turn on ODBC trace set Trace=1
Trace=0
TraceOptions=3

TraceFile=output>/odbctrace.out
TraceDll=directory>/ODBC/V6.0/lib/odbctrac.so
InstallDir=/ODBC/V6.0
UseCursorLib=0
IANAAppCodePage=4
UNICODE=UTF-8

使用mqsisetdbparms MB7BROKER -n ERRORDB -u -p

为MB设置访问数据源的账号和密码
ESQL查询:
SET PartsTable.Part[] = SELECT
P.PartNumber,
P.Description,
P.Price
FROM Database.DSN1.Shop.Parts AS P;
ESQL更新:
UPDATE Database.StockPrices AS SP
SET PRICE = InputBody.Message.StockPrice
WHERE SP.COMPANY = InputBody.Message.Company

ESQL删除
DELETE FROM Database.SHAREHOLDINGS AS S
WHERE S.ACCOUNTNO = InputBody.AccountNumber;
ESQL 新增
INSERT INTO Database.TABLE1(MSGDATA) VALUES (msgBitStream);