CCADOConnection connection(str sqlData = "",
str sqlServer = "",
str sqlAccount = "",
str sqlPassword = "")
{
str connectionStr;
SysSQLSystemInfo systemInfo = SysSQLSystemInfo::construct();
str dataName,sqlIP,dataAccount,dataPwd;
;
if (sqlData) dataName = sqlData; else dataName = systemInfo.getloginDatabase();
if (sqlServer) sqlIp = sqlServer; else sqlIp = systemInfo.getLoginServer();
if (sqlAccount) dataAccount = sqlAccount; else dataAccount = "xxxxxx";
if (sqlPassword) dataPwd = sqlPassword; else dataPwd = "*******";
connectionStr = "Provider = SQLOLEDB.1;" +
"Password =" + dataPwd + ";" +
"Persist Security Info = true;" +
"User Id =" + dataAccount + ";" +
"Initial Catalog =" + dataName + ";" +
"Data Source =" + sqlIp;
cnn = new CCADOConnection();
cnn.open(connectionStr);
cnn.commandTimeout(3600);
return cnn;
}
CCADORecordSet record()
{
;
ccCommand = new CCADOCommand();
ccCommand.activeConnection(this.connection());
record = ccCommand.execute();
return record;
}
job:
CCADOConnection cnn;
CCADOCommand ccCommand;
CCADORecordSet record;
com recordSet;
str strsql;
WL_AdoConnectionSqlData sqldata = new WL_AdoConnectionSqlData();
SqlStatementExecutePermission m_permission;
;
cnn = sqldata.connection();
ccCommand = sqlData.ccCommand();
ccCommand.activeConnection(cnn);
strSql = "select top 10 itemid,itemName from InventTable";
m_permission = new SQLStatementExecutePermission(strSQL);
m_permission.assert();
ccCommand.commandText(strsql);
record = ccCommand.execute();
recordSet = record.recordSet();
CodeAccessPermission::revertAssert();
while (!record.EOF())
{
i++;
sysProgress.setText(strfmt("Searching for requested data records %1", i));
info(record.fields().itemIdx(0).value());
}
cnn.close();
