You are viewing a plain text version of this content. The canonical link for it is here.
Posted to stonehenge-commits@incubator.apache.org by be...@apache.org on 2009/09/16 18:46:08 UTC
svn commit: r815924 [1/2] - in /incubator/stonehenge/trunk/stocktrader:
dotnet/business_service/ dotnet/business_service/BusinessServiceConsole/
dotnet/business_service/BusinessServiceImplementation/
dotnet/common/DALSQLServer/ dotnet/common/StockTrade...
Author: bendewey
Date: Wed Sep 16 18:46:07 2009
New Revision: 815924
URL: http://svn.apache.org/viewvc?rev=815924&view=rev
Log:
STONEHENGE-53 for Joby, Thanks
Added:
incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/SQLServerHelper.cs
Modified:
incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/App.config
incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/BusinessServiceConsole.csproj
incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceImplementation/TradeService.cs
incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceSolution.sln
incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Config.cs
incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Customer.cs
incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/MarketSummary.cs
incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Order.cs
incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/StockTraderDALSQLServer.csproj
incubator/stonehenge/trunk/stocktrader/dotnet/common/StockTraderUtility/SQLHelper.cs
incubator/stonehenge/trunk/stocktrader/dotnet/common/StockTraderUtility/Utility.cs
incubator/stonehenge/trunk/stocktrader/dotnet/config_service/ConfigServiceConfigurationSettings/Settings.cs
incubator/stonehenge/trunk/stocktrader/dotnet/config_service/ConfigServiceConsoleHost/App.config
incubator/stonehenge/trunk/stocktrader/dotnet/config_service/ConfigServiceConsoleHost/ConfigServiceConsoleHost.csproj
incubator/stonehenge/trunk/stocktrader/dotnet/config_service/ConfigServiceSolution.sln
incubator/stonehenge/trunk/stocktrader/dotnet/order_processor/OrderProcessorConsoleServiceHost/App.config
incubator/stonehenge/trunk/stocktrader/dotnet/order_processor/OrderProcessorConsoleServiceHost/OrderProcessorConsoleHost.csproj
incubator/stonehenge/trunk/stocktrader/dotnet/order_processor/OrderProcessorSolution.sln
incubator/stonehenge/trunk/stocktrader/dotnet/setup_utilities/DataLoad/insertdbconfig.sql
incubator/stonehenge/trunk/stocktrader/php/resources/db_scripts/mysql/InsertScript.sql
incubator/stonehenge/trunk/stocktrader/php/resources/db_scripts/mysql/TableCreate.sql
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/App.config
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/App.config?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/App.config (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/App.config Wed Sep 16 18:46:07 2009
@@ -38,6 +38,7 @@
<add key="MinDBConnections" value="20" />
<add key="MaxDBConnections" value="20" />
<add key="DAL" value="Trade.DALSQLServer" />
+ <!--<add key="DAL" value="Trade.DALMySQL" />-->
<add key="ENABLE_GLOBAL_SYSTEM_DOT_TRANSACTIONS_CONFIGSTRING" value="true" />
<add key="SYSTEMDOTTRANSACTION_TIMEOUT" value="0" />
<add key="MAX_QUERY_ORDERS" value="20" />
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/BusinessServiceConsole.csproj
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/BusinessServiceConsole.csproj?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/BusinessServiceConsole.csproj (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceConsole/BusinessServiceConsole.csproj Wed Sep 16 18:46:07 2009
@@ -107,6 +107,10 @@
<Project>{B28867CC-DD77-4F17-BA01-92625C235F6C}</Project>
<Name>OrderProcessorServiceConfigurationSettings</Name>
</ProjectReference>
+ <ProjectReference Include="..\..\common\DALMySQL\StockTraderDALMySQL.csproj">
+ <Project>{DD924D91-04C2-4EBB-AFB9-E96E305E1F07}</Project>
+ <Name>StockTraderDALMySQL</Name>
+ </ProjectReference>
<ProjectReference Include="..\..\common\StockTraderUtility\Utility.csproj">
<Project>{382E6E1C-E430-4F6C-BC41-5D84A3798B02}</Project>
<Name>Utility</Name>
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceImplementation/TradeService.cs
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceImplementation/TradeService.cs?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceImplementation/TradeService.cs (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceImplementation/TradeService.cs Wed Sep 16 18:46:07 2009
@@ -201,7 +201,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -240,7 +240,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -276,7 +276,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -312,7 +312,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -346,7 +346,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString);
@@ -380,7 +380,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -415,7 +415,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -450,7 +450,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString); ;
@@ -491,7 +491,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
@@ -626,7 +626,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalCustomer = Trade.DALFactory.Customer.Create("Trade.DALSQLServer");
+ dalCustomer = Trade.DALFactory.Customer.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalCustomer.Open(connectionString);
@@ -662,7 +662,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalMarketSummary = Trade.DALFactory.MarketSummary.Create("Trade.DALSQLServer");
+ dalMarketSummary = Trade.DALFactory.MarketSummary.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalMarketSummary.Open(connectionString); ;
@@ -698,7 +698,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalMarketSummary = Trade.DALFactory.MarketSummary.Create("Trade.DALSQLServer");
+ dalMarketSummary = Trade.DALFactory.MarketSummary.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
dalMarketSummary.Open(connectionString); ;
@@ -787,7 +787,7 @@
throw new Exception(string.Format(StockTraderUtility.EXCEPTION_MESSAGE_BAD_CONFIG, bsRequest.BSName));
//Create instance of a DAL, which could be designed for any type of DB backend.
- dalOrder = Trade.DALFactory.Order.Create("Trade.DALSQLServer");
+ dalOrder = Trade.DALFactory.Order.Create(SQLHelper.GetAssemblyNameFromDBName(bsConfig.DBName));
var connectionString = SQLHelper.GenerateSqlServerConnectionString(bsConfig.DBHostName, bsConfig.DBPort);
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceSolution.sln
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceSolution.sln?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceSolution.sln (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/business_service/BusinessServiceSolution.sln Wed Sep 16 18:46:07 2009
@@ -45,6 +45,8 @@
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConfigServiceConfigurationSettings", "..\config_service\ConfigServiceConfigurationSettings\ConfigServiceConfigurationSettings.csproj", "{5A192168-838E-4DD1-A5E9-9EE191B941FE}"
EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "StockTraderDALMySQL", "..\common\DALMySQL\StockTraderDALMySQL.csproj", "{DD924D91-04C2-4EBB-AFB9-E96E305E1F07}"
+EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
@@ -119,6 +121,10 @@
{5A192168-838E-4DD1-A5E9-9EE191B941FE}.Debug|Any CPU.Build.0 = Debug|Any CPU
{5A192168-838E-4DD1-A5E9-9EE191B941FE}.Release|Any CPU.ActiveCfg = Release|Any CPU
{5A192168-838E-4DD1-A5E9-9EE191B941FE}.Release|Any CPU.Build.0 = Release|Any CPU
+ {DD924D91-04C2-4EBB-AFB9-E96E305E1F07}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+ {DD924D91-04C2-4EBB-AFB9-E96E305E1F07}.Debug|Any CPU.Build.0 = Debug|Any CPU
+ {DD924D91-04C2-4EBB-AFB9-E96E305E1F07}.Release|Any CPU.ActiveCfg = Release|Any CPU
+ {DD924D91-04C2-4EBB-AFB9-E96E305E1F07}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Config.cs
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Config.cs?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Config.cs (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Config.cs Wed Sep 16 18:46:07 2009
@@ -58,7 +58,7 @@
//_internalADOTransaction: Used only when doing ADO.NET transactions.
//This will be completely ignored when null, and not attached to a cmd object
- //In SQLHelper unless it has been initialized explicitly in the BSL with a
+ //In SQLServerHelper unless it has been initialized explicitly in the BSL with a
//dal.BeginADOTransaction(). See app config setting in web.config and
//Trade.BusinessServiceHost.exe.config "Use System.Transactions Globally" which determines
//whether user wants to run with ADO transactions or System.Transactions. The DAL itself
@@ -112,7 +112,7 @@
//SQL Queries to lookup configuration info for given services
private const string SQL_GET_CLIENT_CONFIG = @"SET NOCOUNT ON; SELECT c.BS, s.URL, s.SEC FROM CLIENTTOBS as c INNER JOIN [SERVICE] AS s ON c.BS = s.SERVICENAME WHERE c.CLIENT = @Client";
private const string SQL_GET_BS_CONFIG = @"SET NOCOUNT ON; SELECT b.OPS, b.URL, b.SEC, d.DBNAME, d.HOSTNAME, d.PORT FROM (SELECT 1 as Row, b1.OPS, s.URL, s.SEC FROM BSTOOPS as b1 INNER JOIN [SERVICE] AS s ON b1.OPS = s.SERVICENAME WHERE b1.BS = @Bs) as b INNER JOIN (SELECT 1 as Row, DBNAME, HOSTNAME, PORT FROM DBCONFIG WHERE ACTIVE='Y') as d ON b.Row = d.Row";
- private const string SQL_GET_OPS_CONFIG = @"SET NOCOUNT ON; SELECT d.DBNAME, d.HOSTNAME, d.PORT FROM dbo.DBCONFIG as d";
+ private const string SQL_GET_OPS_CONFIG = @"SET NOCOUNT ON; SELECT d.DBNAME, d.HOSTNAME, d.PORT FROM dbo.DBCONFIG as d WHERE ACTIVE='Y'";
private const string SQL_FIND_CLIENT_TO_BS = @"SET NOCOUNT ON; SELECT b.CLIENT, b.BS FROM dbo.CLIENTTOBS as b WHERE b.CLIENT = @Client";
private const string SQL_SET_CLIENT_TO_BS = @"INSERT INTO dbo.CLIENTTOBS (CLIENT, BS) VALUES (@Client, @Bs)";
private const string SQL_UPDATE_CLIENT_TO_BS = @"UPDATE dbo.CLIENTTOBS WITH (ROWLOCK) SET BS=@Bs WHERE CLIENT=@Client";
@@ -142,18 +142,18 @@
parm2[1].Value = location.ServiceURL;
parm2[2].Value = location.Sec;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_FIND_SERVICE, parm);
if (!rdr.Read())
{
rdr.Close();
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_INSERT_SERVICE_LOCATION, parm2);
}
else
{
rdr.Close();
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_UPDATE_SERVICE_LOCATION, parm2);
}
}
@@ -168,7 +168,7 @@
{
SqlParameter[] parm = new SqlParameter[] { new SqlParameter(PARM_CLIENT, SqlDbType.VarChar, 50) };
parm[0].Value = client;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_GET_CLIENT_CONFIG, parm);
// Read and Guard
@@ -195,7 +195,7 @@
{
SqlParameter[] parm = new SqlParameter[] { new SqlParameter(PARM_BS, SqlDbType.VarChar, 50) };
parm[0].Value = bs;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_GET_BS_CONFIG, parm);
// Read and Gaurd
@@ -222,7 +222,7 @@
/// <returns>OPSConfigResponse object with config information on the DB connection info</returns>
public OPSConfigResponse GetOPSConfig(string ops)
{
- SqlDataReader rdr = SQLHelper.ExecuteReaderNoParm(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderNoParm(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_GET_OPS_CONFIG);
// Read and Gaurd
@@ -253,17 +253,17 @@
parm2[0].Value = clientConfig.Client;
parm2[1].Value = clientConfig.Bs;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_FIND_CLIENT_TO_BS, parm);
if (!rdr.Read())
{
rdr.Close();
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SET_CLIENT_TO_BS, parm2);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SET_CLIENT_TO_BS, parm2);
}
else
{
rdr.Close();
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_CLIENT_TO_BS, parm2);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_CLIENT_TO_BS, parm2);
}
}
@@ -281,25 +281,25 @@
parm2[0].Value = bsConfig.Bs;
parm2[1].Value = bsConfig.Ops;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRow(_internalConnection, _internalADOTransaction, CommandType.Text,
SQL_FIND_BS_TO_OPS, parm);
if (!rdr.Read())
{
rdr.Close();
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SET_BS_TO_OPS, parm2);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SET_BS_TO_OPS, parm2);
}
else
{
rdr.Close();
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_BS_TO_OPS, parm2);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_BS_TO_OPS, parm2);
}
}
public ServiceLocation[] GetBSLocations()
{
- int count = (int)SQLHelper.ExecuteScalarNoParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_COUNT_BS);
+ int count = (int)SQLServerHelper.ExecuteScalarNoParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_COUNT_BS);
ServiceLocation[] bsLocations = new ServiceLocation[count];
- SqlDataReader rdr = SQLHelper.ExecuteReader(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_GET_BS);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReader(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_GET_BS);
int i = 0;
while (rdr.Read())
{
@@ -316,9 +316,9 @@
public ServiceLocation[] GetOPSLocations()
{
- int count = (int)SQLHelper.ExecuteScalarNoParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_COUNT_OPS);
+ int count = (int)SQLServerHelper.ExecuteScalarNoParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_COUNT_OPS);
ServiceLocation[] opsLocations = new ServiceLocation[count];
- SqlDataReader rdr = SQLHelper.ExecuteReader(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_GET_OPS);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReader(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_GET_OPS);
int i = 0;
while (rdr.Read())
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Customer.cs
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Customer.cs?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Customer.cs (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Customer.cs Wed Sep 16 18:46:07 2009
@@ -72,7 +72,7 @@
//Used only when doing ADO.NET transactions.
//This will be completely ignored when null, and not attached to a cmd object
- //In SQLHelper unless it has been initialized explicitly in the BSL with a
+ //In SQLServerHelper unless it has been initialized explicitly in the BSL with a
//dal.BeginADOTransaction(). See app config setting in web.config and
//Trade.BusinessServiceHost.exe.config "Use System.Transactions Globally" which determines
//whether user wants to run with ADO transactions or System.Transactions. The DAL itself
@@ -174,7 +174,7 @@
}
SqlParameter accountidparm = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
accountidparm.Value = userID;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, commandText,accountidparm);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, commandText,accountidparm);
List<OrderDataModel> orders = new List<OrderDataModel>();
while (rdr.Read())
{
@@ -212,7 +212,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
parm1.Value = userid;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text,SQL_SELECT_CUSTOMERPROFILE_BYUSERID, parm1);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text,SQL_SELECT_CUSTOMERPROFILE_BYUSERID, parm1);
if (rdr.Read())
{
string userPassword = rdr.GetString(1);
@@ -221,7 +221,7 @@
{
SqlParameter profileparm1 = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
profileparm1.Value = userid;
- rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_UPDATE_CUSTOMER_LOGIN, profileparm1);
+ rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_UPDATE_CUSTOMER_LOGIN, profileparm1);
rdr.Read();
AccountDataModel customer = new AccountDataModel(rdr.GetInt32(0), userid, rdr.GetDateTime(1), rdr.GetDecimal(2), rdr.GetInt32(3), rdr.GetDecimal(4), rdr.GetDateTime(5), rdr.GetInt32(6) + 1);
rdr.Close();
@@ -243,7 +243,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
parm1.Value = userid;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_CUSTOMERPROFILE_BYUSERID,parm1);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_CUSTOMERPROFILE_BYUSERID,parm1);
if (rdr.Read())
{
AccountProfileDataModel customerprofile = new AccountProfileDataModel(rdr.GetString(0), rdr.GetString(1), rdr.GetString(2), rdr.GetString(3), rdr.GetString(4), rdr.GetString(5));
@@ -265,7 +265,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
parm1.Value = userID;
- SQLHelper.ExecuteNonQuery(_internalConnection,_internalADOTransaction, CommandType.Text,SQL_UPDATE_LOGOUT, parm1);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection,_internalADOTransaction, CommandType.Text,SQL_UPDATE_LOGOUT, parm1);
return;
}
catch
@@ -280,7 +280,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
parm1.Value = userID;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_GET_CUSTOMER_BYUSERID, parm1);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_GET_CUSTOMER_BYUSERID, parm1);
if (rdr.Read())
{
AccountDataModel customer = new AccountDataModel(rdr.GetInt32(0), rdr.GetString(1), rdr.GetDateTime(2), rdr.GetDecimal(3), rdr.GetInt32(4), rdr.GetDecimal(5), rdr.GetDateTime(6), rdr.GetInt32(7));
@@ -302,7 +302,7 @@
{
SqlParameter useridparm = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
useridparm.Value = userId;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_CLOSED_ORDERS,useridparm);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_CLOSED_ORDERS,useridparm);
List<OrderDataModel> closedorders = new List<OrderDataModel>();
DateTime completionDate = DateTime.MinValue;
while (rdr.Read())
@@ -323,7 +323,7 @@
rdr.Close();
useridparm = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
useridparm.Value = userId;
- SQLHelper.ExecuteNonQuerySingleParm(_internalConnection,_internalADOTransaction, CommandType.Text,SQL_UPDATE_CLOSED_ORDERS,useridparm);
+ SQLServerHelper.ExecuteNonQuerySingleParm(_internalConnection,_internalADOTransaction, CommandType.Text,SQL_UPDATE_CLOSED_ORDERS,useridparm);
}
else
rdr.Close();
@@ -341,7 +341,7 @@
{
SqlParameter useridparm = new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20);
useridparm.Value = userID;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleParm(_internalConnection,_internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDINGS, useridparm);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleParm(_internalConnection,_internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDINGS, useridparm);
List<HoldingDataModel> holdings = new List<HoldingDataModel>();
while (rdr.Read())
{
@@ -363,7 +363,7 @@
{
SqlParameter orderIDparm = new SqlParameter(PARM_ORDERID, SqlDbType.Int);
orderIDparm.Value = orderID;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDING_LOCK, orderIDparm);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDING_LOCK, orderIDparm);
while (rdr.Read())
{
HoldingDataModel holding = new HoldingDataModel(rdr.GetInt32(0), rdr.GetInt32(1), rdr.GetDouble(2), rdr.GetDecimal(3), rdr.GetDateTime(4), rdr.GetString(5));
@@ -386,7 +386,7 @@
new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20)};
holdingidparms[0].Value = holdingid;
holdingidparms[1].Value = userid;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRow(_internalConnection,_internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDING_NOLOCK, holdingidparms);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRow(_internalConnection,_internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDING_NOLOCK, holdingidparms);
while (rdr.Read())
{
HoldingDataModel holding = new HoldingDataModel(holdingid, rdr.GetInt32(0), rdr.GetDouble(1), rdr.GetDecimal(2), rdr.GetDateTime(3), rdr.GetString(4));
@@ -409,7 +409,7 @@
SqlParameter[] accountParms = GetUpdateAccountBalanceParameters();
accountParms[0].Value = total;
accountParms[1].Value = accountID;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_DEBIT_ACCOUNT, accountParms);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_DEBIT_ACCOUNT, accountParms);
}
catch
{
@@ -430,7 +430,7 @@
AccountParms[3].Value = customer.lastLogin;
AccountParms[4].Value = customer.loginCount;
AccountParms[5].Value = customer.profileID;
- customer.accountID = Convert.ToInt32(SQLHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_INSERT_ACCOUNT, AccountParms));
+ customer.accountID = Convert.ToInt32(SQLServerHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_INSERT_ACCOUNT, AccountParms));
return;
}
catch
@@ -451,7 +451,7 @@
ProfileParms[3].Value = customerprofile.email;
ProfileParms[4].Value = customerprofile.creditCard;
ProfileParms[5].Value = customerprofile.fullName;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction,CommandType.Text, SQL_INSERT_ACCOUNTPROFILE, ProfileParms);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction,CommandType.Text, SQL_INSERT_ACCOUNTPROFILE, ProfileParms);
}
catch
{
@@ -471,7 +471,7 @@
ProfileParms[3].Value = customerprofile.creditCard;
ProfileParms[4].Value = customerprofile.fullName;
ProfileParms[5].Value = customerprofile.userID;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_ACCOUNTPROFILE, ProfileParms);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_ACCOUNTPROFILE, ProfileParms);
return customerprofile;
}
catch
@@ -483,14 +483,14 @@
private static SqlParameter[] GetUpdateAccountBalanceParameters()
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_DEBIT_ACCOUNT);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_DEBIT_ACCOUNT);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
parms = new SqlParameter[] {new SqlParameter(PARM_DEBIT, SqlDbType.Decimal, 14),
new SqlParameter(PARM_ACCOUNTID, SqlDbType.Int)};
// Add the parameters to the cached
- SQLHelper.CacheParameters(SQL_DEBIT_ACCOUNT, parms);
+ SQLServerHelper.CacheParameters(SQL_DEBIT_ACCOUNT, parms);
}
return parms;
}
@@ -498,7 +498,7 @@
private static SqlParameter[] GetCreateAccountProfileParameters()
{
// Get the parameters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_INSERT_ACCOUNTPROFILE);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_INSERT_ACCOUNTPROFILE);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -511,7 +511,7 @@
new SqlParameter(PARM_FULLNAME, SqlDbType.VarChar, StockTraderUtility.FULLNAME_MAX_LENGTH)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_INSERT_ACCOUNTPROFILE, parms);
+ SQLServerHelper.CacheParameters(SQL_INSERT_ACCOUNTPROFILE, parms);
}
return parms;
}
@@ -519,7 +519,7 @@
private static SqlParameter[] GetUpdateAccountProfileParameters()
{
// Get the parameters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_UPDATE_ACCOUNTPROFILE);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_UPDATE_ACCOUNTPROFILE);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -532,7 +532,7 @@
new SqlParameter(PARM_USERID, SqlDbType.VarChar, StockTraderUtility.USERID_MAX_LENGTH)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_UPDATE_ACCOUNTPROFILE, parms);
+ SQLServerHelper.CacheParameters(SQL_UPDATE_ACCOUNTPROFILE, parms);
}
return parms;
}
@@ -540,7 +540,7 @@
private static SqlParameter[] GetCreateAccountParameters()
{
// Get the parameters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_INSERT_ACCOUNT);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_INSERT_ACCOUNT);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -553,7 +553,7 @@
new SqlParameter(PARM_USERID, SqlDbType.VarChar, StockTraderUtility.USERID_MAX_LENGTH)};
// Add the parameters to the cached
- SQLHelper.CacheParameters(SQL_INSERT_ACCOUNT, parms);
+ SQLServerHelper.CacheParameters(SQL_INSERT_ACCOUNT, parms);
}
return parms;
}
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/MarketSummary.cs
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/MarketSummary.cs?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/MarketSummary.cs (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/MarketSummary.cs Wed Sep 16 18:46:07 2009
@@ -59,7 +59,7 @@
//Used only when doing ADO.NET transactions.
//This will be completely ignored when null, and not attached to a cmd object
- //In SQLHelper unless it has been initialized explicitly in the BSL with a
+ //In SQLServerHelper unless it has been initialized explicitly in the BSL with a
//dal.BeginADOTransaction(). See app config setting in web.config and
//Trade.BusinessServiceHost.exe.config "Use System.Transactions Globally" which determines
//whether user wants to run with ADO transactions or System.Transactions. The DAL itself
@@ -132,7 +132,7 @@
updatestockpriceparm[2].Value = quote.symbol;
updatestockpriceparm[3].Value = quote.low;
updatestockpriceparm[4].Value = quote.high;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_STOCKPRICEVOLUME, updatestockpriceparm);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_STOCKPRICEVOLUME, updatestockpriceparm);
return;
}
catch
@@ -147,7 +147,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_SYMBOL, SqlDbType.VarChar, 10);
parm1.Value = symbol;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction,CommandType.Text, SQL_SELECT_QUOTE_NOLOCK,parm1);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction,CommandType.Text, SQL_SELECT_QUOTE_NOLOCK,parm1);
QuoteDataModel quote = null;
if (rdr.HasRows)
{
@@ -169,7 +169,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_SYMBOL, SqlDbType.VarChar, 10);
parm1.Value = symbol;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_QUOTE, parm1);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_QUOTE, parm1);
QuoteDataModel quote = null;
if (rdr.HasRows)
{
@@ -189,10 +189,10 @@
{
try
{
- decimal TSIA = (decimal)SQLHelper.ExecuteScalarNoParm(_internalConnection,_internalADOTransaction, CommandType.Text,SQL_SELECT_MARKETSUMMARY_TSIA);
- decimal openTSIA = (decimal)SQLHelper.ExecuteScalarNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_OPENTSIA);
- double totalVolume = (double)SQLHelper.ExecuteScalarNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_VOLUME);
- SqlDataReader rdr = SQLHelper.ExecuteReaderNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_GAINERS);
+ decimal TSIA = (decimal)SQLServerHelper.ExecuteScalarNoParm(_internalConnection,_internalADOTransaction, CommandType.Text,SQL_SELECT_MARKETSUMMARY_TSIA);
+ decimal openTSIA = (decimal)SQLServerHelper.ExecuteScalarNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_OPENTSIA);
+ double totalVolume = (double)SQLServerHelper.ExecuteScalarNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_VOLUME);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_GAINERS);
List<QuoteDataModel> topgainers = new List<QuoteDataModel>();
List<QuoteDataModel> toplosers = new List<QuoteDataModel>();
int i = 0;
@@ -202,7 +202,7 @@
topgainers.Add(quote);
}
rdr.Close();
- rdr = SQLHelper.ExecuteReaderNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_LOSERS);
+ rdr = SQLServerHelper.ExecuteReaderNoParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_SELECT_MARKETSUMMARY_LOSERS);
i = 0;
while (rdr.Read() && i++ < 5)
{
@@ -222,7 +222,7 @@
private static SqlParameter[] GetUpdateStockPriceVolumeParameters()
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_UPDATE_STOCKPRICEVOLUME);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_UPDATE_STOCKPRICEVOLUME);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -233,7 +233,7 @@
new SqlParameter(PARM_LOW, SqlDbType.Decimal, 14),
new SqlParameter(PARM_HIGH, SqlDbType.Decimal, 14)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_UPDATE_STOCKPRICEVOLUME, parms);
+ SQLServerHelper.CacheParameters(SQL_UPDATE_STOCKPRICEVOLUME, parms);
}
return parms;
}
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Order.cs
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Order.cs?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Order.cs (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/Order.cs Wed Sep 16 18:46:07 2009
@@ -59,7 +59,7 @@
//_internalADOTransaction: Used only when doing ADO.NET transactions.
//This will be completely ignored when null, and not attached to a cmd object
- //In SQLHelper unless it has been initialized explicitly in the BSL with a
+ //In SQLServerHelper unless it has been initialized explicitly in the BSL with a
//dal.BeginADOTransaction(). See app config setting in web.config and
//Trade.BusinessServiceHost.exe.config "Use System.Transactions Globally" which determines
//whether user wants to run with ADO transactions or System.Transactions. The DAL itself
@@ -169,7 +169,7 @@
order.holdingID = holdingID;
SqlParameter[] parm = new SqlParameter[]{new SqlParameter(PARM_USERID, SqlDbType.VarChar, 20)};
parm[0].Value = userID;
- order.accountID = Convert.ToInt32(SQLHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_GET_ACCOUNTID, parm));
+ order.accountID = Convert.ToInt32(SQLServerHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_GET_ACCOUNTID, parm));
SqlParameter[] OrderParms = GetCreateOrderParameters();
OrderParms[0].Value = order.orderFee;
OrderParms[1].Value = order.price;
@@ -178,7 +178,7 @@
OrderParms[4].Value = order.orderType;
OrderParms[5].Value = order.accountID;
OrderParms[6].Value = holdingID;
- order.orderID = Convert.ToInt32(SQLHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_INSERT_ORDER, OrderParms));
+ order.orderID = Convert.ToInt32(SQLServerHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_INSERT_ORDER, OrderParms));
return order;
}
catch
@@ -191,7 +191,7 @@
{
SqlParameter parm1 = new SqlParameter(PARM_HOLDINGID, SqlDbType.Int, 10);
parm1.Value = holdingID;
- SqlDataReader rdr = SQLHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDING, parm1);
+ SqlDataReader rdr = SQLServerHelper.ExecuteReaderSingleRowSingleParm(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_SELECT_HOLDING, parm1);
if (rdr.Read())
{
HoldingDataModel holding = new HoldingDataModel(rdr.GetInt32(0), rdr.GetDouble(1), rdr.GetDecimal(2), rdr.GetDateTime(3), rdr.GetString(4), rdr.GetInt32(5));
@@ -208,14 +208,14 @@
{
SqlParameter orderParm = new SqlParameter(PARM_ORDERID, SqlDbType.Int, 10);
orderParm.Value = order.orderID;
- order.accountID = Convert.ToInt32(SQLHelper.ExecuteScalarSingleParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_GET_ACCOUNTID_ORDER,orderParm));
+ order.accountID = Convert.ToInt32(SQLServerHelper.ExecuteScalarSingleParm(_internalConnection,_internalADOTransaction,CommandType.Text,SQL_GET_ACCOUNTID_ORDER,orderParm));
SqlParameter[] HoldingParms = GetCreateHoldingParameters();
HoldingParms[0].Value = order.price;
HoldingParms[1].Value = (float)order.quantity;
HoldingParms[2].Value = order.openDate;
HoldingParms[3].Value = order.accountID;
HoldingParms[4].Value = order.symbol;
- int holdingid = SQLHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_INSERT_HOLDING, HoldingParms);
+ int holdingid = SQLServerHelper.ExecuteScalar(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_INSERT_HOLDING, HoldingParms);
return holdingid;
}
catch
@@ -231,7 +231,7 @@
SqlParameter[] HoldingParms2 = GetUpdateHoldingParameters();
HoldingParms2[0].Value = holdingid;
HoldingParms2[1].Value = quantity;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_HOLDING, HoldingParms2);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_HOLDING, HoldingParms2);
HoldingDataModel holding = new HoldingDataModel();
return;
}
@@ -247,7 +247,7 @@
{
SqlParameter[] HoldingParms2 = { new SqlParameter(PARM_HOLDINGID, SqlDbType.Int) };
HoldingParms2[0].Value = holdingid;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_DELETE_HOLDING, HoldingParms2);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_DELETE_HOLDING, HoldingParms2);
return;
}
catch
@@ -263,7 +263,7 @@
SqlParameter[] orderparms = GetUpdateOrderParameters();
orderparms[0].Value = order.quantity;
orderparms[1].Value = order.orderID;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_ORDER, orderparms);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_UPDATE_ORDER, orderparms);
}
catch
{
@@ -284,7 +284,7 @@
closeorderparm[1].Value = order.holdingID;
closeorderparm[2].Value = order.price;
closeorderparm[3].Value = order.orderID;
- SQLHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_CLOSE_ORDER, closeorderparm);
+ SQLServerHelper.ExecuteNonQuery(_internalConnection, _internalADOTransaction, CommandType.Text, SQL_CLOSE_ORDER, closeorderparm);
}
catch
{
@@ -296,7 +296,7 @@
private static SqlParameter[] GetCreateOrderParameters()
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_INSERT_ORDER);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_INSERT_ORDER);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -309,7 +309,7 @@
new SqlParameter(PARM_ACCOUNTID, SqlDbType.Int, 10),
new SqlParameter(PARM_HOLDINGID, SqlDbType.Int,10)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_INSERT_ORDER, parms);
+ SQLServerHelper.CacheParameters(SQL_INSERT_ORDER, parms);
}
return parms;
}
@@ -317,14 +317,14 @@
private static SqlParameter[] GetUpdateOrderParameters()
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_UPDATE_ORDER);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_UPDATE_ORDER);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
parms = new SqlParameter[] {new SqlParameter(PARM_QUANTITY, SqlDbType.Float),
new SqlParameter(PARM_ORDERID,SqlDbType.Int)};
- SQLHelper.CacheParameters(SQL_UPDATE_ORDER, parms);
+ SQLServerHelper.CacheParameters(SQL_UPDATE_ORDER, parms);
}
return parms;
}
@@ -333,7 +333,7 @@
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_INSERT_HOLDING);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_INSERT_HOLDING);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -345,7 +345,7 @@
new SqlParameter(PARM_SYMBOL, SqlDbType.VarChar,20)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_INSERT_HOLDING, parms);
+ SQLServerHelper.CacheParameters(SQL_INSERT_HOLDING, parms);
}
return parms;
}
@@ -353,14 +353,14 @@
private static SqlParameter[] GetUpdateHoldingParameters()
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_UPDATE_HOLDING);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_UPDATE_HOLDING);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
parms = new SqlParameter[] {new SqlParameter(PARM_HOLDINGID, SqlDbType.Int),
new SqlParameter(PARM_QUANTITY, SqlDbType.Float)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_UPDATE_HOLDING, parms);
+ SQLServerHelper.CacheParameters(SQL_UPDATE_HOLDING, parms);
}
return parms;
}
@@ -368,7 +368,7 @@
private static SqlParameter[] GetCloseOrdersParameters()
{
// Get the paramters from the cache
- SqlParameter[] parms = SQLHelper.GetCacheParameters(SQL_CLOSE_ORDER);
+ SqlParameter[] parms = SQLServerHelper.GetCacheParameters(SQL_CLOSE_ORDER);
// If the cache is empty, rebuild the parameters
if (parms == null)
{
@@ -379,7 +379,7 @@
new SqlParameter(PARM_ORDERID, SqlDbType.Int)};
// Add the parametes to the cached
- SQLHelper.CacheParameters(SQL_CLOSE_ORDER, parms);
+ SQLServerHelper.CacheParameters(SQL_CLOSE_ORDER, parms);
}
return parms;
}
Added: incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/SQLServerHelper.cs
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/SQLServerHelper.cs?rev=815924&view=auto
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/SQLServerHelper.cs (added)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/SQLServerHelper.cs Wed Sep 16 18:46:07 2009
@@ -0,0 +1,331 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+// .NET Service Configuration V2.0 for Design Considerations for Service-Oriented Applications based on Windows Communication Foundation. Created with Microsoft .NET Framework 3.5 and Microsoft Visual Studio. Copyright 2008, Microsoft Corporation.
+
+//======================================================================================================
+//This file contains SQLServerHelper logic, largely derived/modified from the MSDN Data Access Block. It
+//has the methods that perform ALL ADO.NET operations.
+//======================================================================================================
+
+using System;
+using System.Configuration;
+using System.Data;
+using System.Data.SqlClient;
+using System.Collections;
+
+namespace Trade.DALSQLServer
+{
+ public abstract class SQLServerHelper
+ {
+
+ // Hashtable to store cached parameters
+ private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());
+
+
+ /// <summary>
+ /// Create and execute a command to return DataReader after binding to a single parameter.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="singleParm">The single SqlParameter object to bind to the query.</param>
+ public static SqlDataReader ExecuteReaderSingleParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter singleParm)
+ {
+ SqlCommand cmd = new SqlCommand();
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ cmd.Parameters.Add(singleParm);
+ SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.SingleResult);
+ return rdr;
+ }
+
+ /// <summary>
+ /// Create and execute a command to return a single-row DataReader after binding to a single parameter.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="singleParm">The single SqlParameter object to bind to the query.</param>
+ public static SqlDataReader ExecuteReaderSingleRowSingleParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter singleParm)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ cmd.Parameters.Add(singleParm);
+ SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.SingleRow);
+ return rdr;
+ }
+
+ /// <summary>
+ /// Create and execute a command to return a single-row DataReader after binding to multiple parameters.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="cmdParms">An array of SqlParameter objects to bind to the query.</param>
+ public static SqlDataReader ExecuteReaderSingleRow(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ PrepareCommand(cmd, cmdParms);
+ SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.SingleRow);
+ return rdr;
+ }
+
+ /// <summary>
+ /// Create and execute a command to return a DataReader, no parameters used in the command.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ public static SqlDataReader ExecuteReaderNoParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.SingleResult);
+ return rdr;
+ }
+
+ /// <summary>
+ /// Create and execute a command to return a DataReader after binding to multiple parameters.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="cmdParms">An array of SqlParameter objects to bind to the query.</param>
+ public static SqlDataReader ExecuteReader(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ PrepareCommand(cmd, cmdParms);
+ SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.SingleResult);
+ return rdr;
+ }
+
+ /// <summary>
+ /// Create and execute a command to return a single scalar (int) value after binding to multiple parameters.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="cmdParms">An array of SqlParameter objects to bind to the query.</param>
+ public static int ExecuteScalar(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.CommandText = cmdText;
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ PrepareCommand(cmd, cmdParms);
+ int val = Convert.ToInt32(cmd.ExecuteScalar());
+ return val;
+ }
+
+
+ /// <summary>
+ /// Create and execute a command to return a single scalar (int) value after binding to a single parameter.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="singleParm">A SqlParameter object to bind to the query.</param>
+ public static int ExecuteScalarSingleParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter singleParm)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.CommandText = cmdText;
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.Parameters.Add(singleParm);
+ int val = Convert.ToInt32(cmd.ExecuteScalar());
+ return val;
+ }
+
+ /// <summary>
+ /// Create and execute a command to return a single scalar (int) value. No parameters will be bound to the command.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="singleParm">A SqlParameter object to bind to the query.</param>
+ public static object ExecuteScalarNoParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.CommandText = cmdText;
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ object val = cmd.ExecuteScalar();
+ return val;
+ }
+
+ /// <summary>
+ /// Create and execute a command that returns no result set after binding to multiple parameters.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="cmdParms">An array of SqlParameter objects to bind to the query.</param>
+ public static int ExecuteNonQuery(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ PrepareCommand(cmd, cmdParms);
+ int val = cmd.ExecuteNonQuery();
+ return val;
+ }
+
+ /// <summary>
+ /// Create and execute a command that returns no result set after binding to a single parameter.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="singleParam">A SqlParameter object to bind to the query.</param>
+ public static int ExecuteNonQuerySingleParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter singleParam)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ cmd.Parameters.Add(singleParam);
+ int val = cmd.ExecuteNonQuery();
+ return val;
+ }
+
+ /// <summary>
+ /// Create and execute a command that returns no result set after binding to a single parameter.
+ /// </summary>
+ /// <param name="conn">Connection to execute against. If not open, it will be here.</param>
+ /// <param name="trans">ADO transaction. If null, will not be attached to the command</param>
+ /// <param name="cmdType">Type of ADO command; such as Text or Procedure</param>
+ /// <param name="cmdText">The actual SQL or the name of the Stored Procedure depending on command type</param>
+ /// <param name="singleParam">A SqlParameter object to bind to the query.</param>
+ public static int ExecuteNonQueryNoParm(SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ SqlCommand cmd = new SqlCommand();
+ cmd.Connection = conn;
+ if (trans != null)
+ cmd.Transaction = trans;
+ cmd.CommandText = cmdText;
+ int val = cmd.ExecuteNonQuery();
+ return val;
+ }
+
+ /// <summary>
+ /// add parameter array to the cache
+ /// </summary>
+ /// <param name="cacheKey">Key to the parameter cache</param>
+ /// <param name="cmdParms">an array of SqlParamters to be cached</param>
+ public static void CacheParameters(string cacheKey, params SqlParameter[] cmdParms)
+ {
+ parmCache[cacheKey] = cmdParms;
+ }
+
+ /// <summary>
+ /// Retrieve cached parameters
+ /// </summary>
+ /// <param name="cacheKey">key used to lookup parameters</param>
+ /// <returns>Cached SqlParamters array</returns>
+ public static SqlParameter[] GetCacheParameters(string cacheKey)
+ {
+ SqlParameter[] cachedParms = (SqlParameter[])parmCache[cacheKey];
+
+ if (cachedParms == null)
+ return null;
+
+ SqlParameter[] clonedParms = new SqlParameter[cachedParms.Length];
+
+ for (int i = 0, j = cachedParms.Length; i < j; i++)
+ clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone();
+
+ return clonedParms;
+ }
+
+ /// <summary>
+ /// Prepare a command for execution
+ /// </summary>
+ /// <param name="cmd">SqlCommand object</param>
+ /// <param name="conn">SqlConnection object</param>
+ /// <param name="trans">SqlTransaction object</param>
+ /// <param name="cmdType">Cmd type e.g. stored procedure or text</param>
+ /// <param name="cmdText">Command text, e.g. Select * from Products</param>
+ /// <param name="cmdParms">SqlParameters to use in the command</param>
+ private static void PrepareCommand(SqlCommand cmd, SqlParameter[] cmdParms)
+ {
+ if (cmdParms != null)
+ {
+ for (int i = 0; i < cmdParms.Length; i++)
+ {
+ SqlParameter parm = (SqlParameter)cmdParms[i];
+ cmd.Parameters.Add(parm);
+ }
+ }
+ }
+
+ }
+}
Modified: incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/StockTraderDALSQLServer.csproj
URL: http://svn.apache.org/viewvc/incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/StockTraderDALSQLServer.csproj?rev=815924&r1=815923&r2=815924&view=diff
==============================================================================
--- incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/StockTraderDALSQLServer.csproj (original)
+++ incubator/stonehenge/trunk/stocktrader/dotnet/common/DALSQLServer/StockTraderDALSQLServer.csproj Wed Sep 16 18:46:07 2009
@@ -71,6 +71,7 @@
<Compile Include="MarketSummary.cs" />
<Compile Include="Order.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
+ <Compile Include="SQLServerHelper.cs" />
</ItemGroup>
<ItemGroup>
<Content Include="stocktrader.snk" />