本文整理汇总了C#中Microsoft.Practices.EnterpriseLibrary.Data.Sql.SqlDatabase类的典型用法代码示例。如果您正苦于以下问题:C# SqlDatabase类的具体用法?C# SqlDatabase怎么用?C# SqlDatabase使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SqlDatabase类属于Microsoft.Practices.EnterpriseLibrary.Data.Sql命名空间,在下文中一共展示了SqlDatabase类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: addNewUser
public int addNewUser(string firstname, string lastname, string companyname, string email, string password, string countryid, string stateid, string mobile, int type, string verify)
{
int status = 0;
try
{
Guid guid = Guid.NewGuid();
Database objDB = new SqlDatabase(connectionStr);
DbCommand objAdd = new SqlCommand();
objAdd.CommandType = CommandType.StoredProcedure;
objAdd.CommandText = "InsertUser";
objDB.AddInParameter(objAdd, "@FName", DbType.String, firstname);
objDB.AddInParameter(objAdd, "@LName", DbType.String, lastname);
objDB.AddInParameter(objAdd, "@Companyname", DbType.String, companyname);
objDB.AddInParameter(objAdd, "@Email", DbType.String, email);
objDB.AddInParameter(objAdd, "@Password", DbType.String, password);
objDB.AddInParameter(objAdd, "@Countryid", DbType.Int32, countryid);
objDB.AddInParameter(objAdd, "@Stateid", DbType.Int32, stateid);
objDB.AddInParameter(objAdd, "@Mobile", DbType.String, mobile);
objDB.AddInParameter(objAdd, "@Type", DbType.Int32, type);
objDB.AddInParameter(objAdd, "@Verify", DbType.String, verify);
objDB.AddOutParameter(objAdd, "@Stat", DbType.Int16, 16);
objDB.ExecuteNonQuery(objAdd);
status = Convert.ToInt16(objDB.GetParameterValue(objAdd, "@Stat"));
return status;
}
catch (Exception ex)
{
objErr.GeneralExceptionHandling(ex, "Website - User Registration", "addNewUser", "GENERAL EXCEPTION");
return status;
}
}
开发者ID:pratikmoda,项目名称:StockLotDirect,代码行数:32,代码来源:BL_Login.cs
示例2: btnProcessManualBox_Click
protected void btnProcessManualBox_Click( object sender, EventArgs e )
{
StatGrabber.StatGrabber sg = new StatGrabber.StatGrabber();
SqlDatabase db = new SqlDatabase( System.Configuration.ConfigurationManager.AppSettings["ConnectionString"] );
ArrayList problems = new ArrayList();
try
{
ArrayList perfs = sg.GetGamePerformances( tbManualBoxURL.Text, problems );
tbOutput.Text += "Got " + perfs.Count + " perfs from " + tbManualBoxURL.Text + "\r\n";
problems.AddRange( sg.SavePerformances( db, perfs, calStatDate.SelectedDate ) );
}
catch( StatGrabber.StatGrabberException ex )
{
tbOutput.Text += ex.Message;
}
if( problems.Count > 0 )
{
tbOutput.Text += "Problems:\r\n";
foreach( StatGrabber.PlayerPerformance p in problems )
{
tbOutput.Text += p.FirstName + " " + p.LastName + " " + p.TeamName + "\r\n";
}
}
else
{
tbOutput.Text += "No problems identifying players\r\n";
}
tbOutput.Text += sg.UpdateAveragesAndScores( db, calStatDate.SelectedDate );
Log.AddLogEntry(
LogEntryTypes.StatsProcessed,
Page.User.Identity.Name,
tbOutput.Text );
}
开发者ID:ohri,项目名称:netcaa,代码行数:35,代码来源:Scoring.aspx.cs
示例3: addInquiry
public int addInquiry(string name, string email, string subject, string message)
{
int status = 0;
try
{
Database objDB = new SqlDatabase(connectionStr);
DbCommand objAdd = new SqlCommand();
objAdd.CommandType = CommandType.StoredProcedure;
objAdd.CommandText = "InsertInquiry";
objDB.AddInParameter(objAdd, "@Name", DbType.String, name);
objDB.AddInParameter(objAdd, "@Email", DbType.String, email);
objDB.AddInParameter(objAdd, "@Subject", DbType.String, subject);
objDB.AddInParameter(objAdd, "@Message", DbType.String, message);
objDB.AddOutParameter(objAdd, "@Stat", DbType.Int16, 16);
objDB.ExecuteNonQuery(objAdd);
status = Convert.ToInt16(objDB.GetParameterValue(objAdd, "@Stat"));
return status;
}
catch (Exception ex)
{
objCommom.LogFile("Contact.aspx", "addInquiry", ex);
return status;
}
}
开发者ID:pratikmoda,项目名称:GreyMediaHouse,代码行数:25,代码来源:BL_Contact.cs
示例4: GetCustomer
public override CustomerList GetCustomer(string vipCode)
{
SqlDatabase database = new SqlDatabase(ConnectionString);
DbCommand command = database.GetStoredProcCommand("rmSP_WSPOS_GetCustomer");
command.CommandTimeout = 300;
database.AddInParameter(command, "@VipCode", DbType.String, vipCode);
List<Customer> customers = new List<Customer>();
using (IDataReader reader = database.ExecuteReader(command))
{
while (reader.Read())
{
Customer customer = new Customer();
customer.CustomerId = Convert.ToInt32(reader["VIPCode_id"]);
customer.CustomerCode = reader["VipCode"] as string;
customer.FirstName = reader["VIPGName"] as string;
customer.LastName = reader["VIPName"] as string;
customer.Telephone = reader["VIPTel"] as string;
if (reader["VIPBDay"] != DBNull.Value)
customer.BirthDate = Convert.ToDateTime(reader["VIPBDay"]);
customers.Add(customer);
}
}
CustomerList customerList = new CustomerList();
customerList.Customers = customers;
customerList.TotalCount = customers.Count;
return customerList;
}
开发者ID:GaryDev,项目名称:webservice-net,代码行数:30,代码来源:DataProviderMSSQL.cs
示例5: Autosub
protected string Autosub( string weekId, SqlDatabase db, DateTime selectedDate )
{
string result = AutoSub.ProcessAutosubs( weekId );
StatGrabber.StatGrabber sg = new StatGrabber.StatGrabber();
result += sg.UpdateAveragesAndScores( db, selectedDate );
return result;
}
开发者ID:ohri,项目名称:netba,代码行数:7,代码来源:Scoring.aspx.cs
示例6: Page_Load
protected void Page_Load(object sender, EventArgs e)
{
if (!IsPostBack)
{
Database objDB = new SqlDatabase(M_CONSTR);
if (objDB != null)
{
//所属部门
DataSet ds = objDB.ExecuteDataSet(CommandType.Text, "SELECT * FROM Table_Group");
ddlTGroup.DataSource = ds.Tables[0];
ddlTGroup.DataTextField = "GroupName";
ddlTGroup.DataValueField = "GroupID";
ddlTGroup.DataBind();
ddlTGroup.Items.Insert(0, (new ListItem("--全部--", "0")));
ddlTGroup.SelectedIndex = 0;
//讲师
ds = objDB.ExecuteDataSet(CommandType.Text, "SELECT * FROM Table_TEACHER");
ddlTeacher.DataSource = ds.Tables[0];
ddlTeacher.DataTextField = "TeacherName";
ddlTeacher.DataValueField = "TeacherID";
ddlTeacher.DataBind();
//ddlTeacher.Items.Insert(0, (new ListItem("--全部--", "0")));
//ddlTeacher.SelectedIndex = 0;
}
}
}
开发者ID:conghuiw,项目名称:dcwj,代码行数:27,代码来源:selteacher.aspx.cs
示例7: DoLotsOfConnectionFailures
public void DoLotsOfConnectionFailures()
{
int numberOfEvents = 50;
using (WmiEventWatcher eventListener = new WmiEventWatcher(numberOfEvents))
{
SqlDatabase db = new SqlDatabase("BadConnectionString");
DataInstrumentationListener listener = new DataInstrumentationListener("foo", true, true, true);
DataInstrumentationListenerBinder binder = new DataInstrumentationListenerBinder();
binder.Bind(db.GetInstrumentationEventProvider(), listener);
for (int i = 0; i < numberOfEvents; i++)
{
try
{
db.ExecuteScalar(CommandType.Text, "Select count(*) from Region");
}
catch { }
}
eventListener.WaitForEvents();
Assert.AreEqual(numberOfEvents, eventListener.EventsReceived.Count);
Assert.AreEqual("ConnectionFailedEvent", eventListener.EventsReceived[0].ClassPath.ClassName);
Assert.AreEqual("foo", eventListener.EventsReceived[0].GetPropertyValue("InstanceName"));
Assert.AreEqual(db.ConnectionStringWithoutCredentials, eventListener.EventsReceived[0].GetPropertyValue("ConnectionString"));
}
}
开发者ID:ChiangHanLung,项目名称:PIC_VDS,代码行数:27,代码来源:DataInstrumentationListenerFixture.cs
示例8: Departments
public static IDataReader Departments()
{
SqlDatabase db = new SqlDatabase(connString);
DbCommand command = db.GetSqlStringCommand("SELECT DeptId, Name FROM AllDepartments D WHERE D.Active=1 AND D.NormBillsTime=1 ORDER BY Name");
command.CommandType = CommandType.Text;
return db.ExecuteReader(command);
}
开发者ID:the0ther,项目名称:how2www.info,代码行数:7,代码来源:Department.cs
示例9: ToDataReader
public IDataReader ToDataReader(string storedProcedureName, Dictionary<string, string> parameters)
{
using (SqlCommand cmd = new SqlCommand(storedProcedureName))
{
cmd.CommandType = CommandType.StoredProcedure;
foreach (string key in parameters.Keys)
{
SqlParameter parameter = new SqlParameter(key, parameters[key]);
if (parameter.Value == null)
parameter.Value = DBNull.Value;
if (parameter.SqlDbType == SqlDbType.DateTime && parameter.Value is DateTime && (DateTime)parameter.Value == default(DateTime))
parameter.Value = SqlDateTime.MinValue.Value;
cmd.Parameters.Add(parameter);
}
SqlDatabase database = new SqlDatabase(ConfigurationManager.ConnectionStrings["MyAppsLocal"].ConnectionString);
try
{
IDataReader reader = database.ExecuteReader(cmd);
return reader;
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
return null;
}
}
}
开发者ID:pr0z,项目名称:MyAppointments,代码行数:34,代码来源:BaseCrud.cs
示例10: GetResources
public static DataTable GetResources(int jobId, int deptId)
{
SqlDatabase db = new SqlDatabase(connString);
string sql = @" SELECT U.UserId, U.FirstName + ' ' + U.LastName AS FullName,
t.TitleName as Title
FROM AllocableUsers U LEFT JOIN JobTitles AS t ON U.currentTitleID=t.TitleID
WHERE U.Active=1 AND U.UserId NOT IN (
SELECT UserId FROM Assignments WHERE [email protected]_id
AND (EndDate IS NULL OR EndDate>DATEADD(s, 1, CURRENT_TIMESTAMP)))
AND [email protected]_id AND realPerson='Y'
AND UserId NOT IN (
SELECT UserId
FROM timeEntry
WHERE [email protected]_id AND UserId=U.UserId AND (TimeSpan IS NULL OR TimeSpan > 0)
)
ORDER BY FullName";
DbCommand command = db.GetSqlStringCommand(sql);
db.AddInParameter(command, "@job_id", DbType.Int32, jobId);
db.AddInParameter(command, "@dept_id", DbType.Int32, deptId);
DataTable t = new DataTable();
t = db.ExecuteDataSet(command).Tables[0].Copy();
t.TableName = "Resources";
command.Dispose();
return t;
}
开发者ID:the0ther,项目名称:how2www.info,代码行数:26,代码来源:ManageAssignments.cs
示例11: GetIDataReader
public static IDataReader GetIDataReader(string connectionString, string sqlQuery)
{
SqlDatabase sqlServerDB = new SqlDatabase(connectionString);
DbCommand cmd = sqlServerDB.GetSqlStringCommand(sqlQuery);
//return an IDataReader.
return sqlServerDB.ExecuteReader(cmd);
}
开发者ID:namanbansal,项目名称:NotificationProcessor,代码行数:7,代码来源:WebhookNotificationBAL.cs
示例12: GetImportedRecords
//fetch record
public static DataTable GetImportedRecords(int? top = 1000, bool direction = true, string name = "",
bool? gender = null, int? year = null, long? rank = null)
{
Database objDB = new SqlDatabase(ConfigurationManager.ConnectionStrings["DBaseConnectionString"].ConnectionString);
DataSet _ds = new DataSet();
using (DbCommand objCMD = objDB.GetStoredProcCommand("PSP_Babies_Get"))
{
objDB.AddInParameter(objCMD, "@Top",
DbType.Int32, top??1000000);
objDB.AddInParameter(objCMD, "@SortingDirection",
DbType.String, direction.ToIndicator());
objDB.AddInParameter(objCMD, "@Name",
DbType.String, name);
objDB.AddInParameter(objCMD, "@Gender",
DbType.String, gender.ToIndicator());
objDB.AddInParameter(objCMD, "@Year",
DbType.Int32, year);
objDB.AddInParameter(objCMD, "@Rank",
DbType.Int64, rank);
try
{
_ds = objDB.ExecuteDataSet(objCMD);
return _ds != null ? _ds.Tables[0] : new DataTable();
}
catch (Exception ex)
{
throw ex;
}
}
}
开发者ID:AmithRajMP,项目名称:mini-project,代码行数:33,代码来源:BabiesDataAccess.cs
示例13: SaveBaby
public static void SaveBaby(string babyName, long position, bool gender, int year, long rank)
{
Database objDB = new SqlDatabase(ConfigurationManager.ConnectionStrings["DBaseConnectionString"].ConnectionString);
using (DbCommand objCMD = objDB.GetStoredProcCommand("PSP_Babies_Save"))
{
objDB.AddInParameter(objCMD, "@Name",
DbType.String, babyName);
objDB.AddInParameter(objCMD, "@Gender",
DbType.String, gender.ToIndicator());
objDB.AddInParameter(objCMD, "@Position",
DbType.Int64, position);
objDB.AddInParameter(objCMD, "@Rank",
DbType.Int64, rank);
objDB.AddInParameter(objCMD, "@Year",
DbType.Int32, year);
//objDB.AddOutParameter(objCMD, "@strMessage", DbType.String, 255);
try
{
objDB.ExecuteNonQuery(objCMD);
}
catch (Exception ex)
{
throw ex;
}
}
}
开发者ID:AmithRajMP,项目名称:mini-project,代码行数:28,代码来源:BabiesDataAccess.cs
示例14: addNewProductPost
public int addNewProductPost(string userid, int l1id, int l2id, int l3id, string productname, string keywords, string description, decimal quantity, decimal price, string image1,
string image2, string image3, string image4)
{
int status = 0;
try
{
Guid guid = new Guid(userid);
Database objDB = new SqlDatabase(connectionStr);
DbCommand objAdd = new SqlCommand();
objAdd.CommandType = CommandType.StoredProcedure;
objAdd.CommandText = "InsertProductPost";
objDB.AddInParameter(objAdd, "@USERID", DbType.Guid, guid);
objDB.AddInParameter(objAdd, "@L1ID", DbType.Int32, l1id);
objDB.AddInParameter(objAdd, "@L2ID", DbType.Int32, l2id);
objDB.AddInParameter(objAdd, "@L3ID", DbType.Int32, l3id);
objDB.AddInParameter(objAdd, "@PRODUCTNAME", DbType.String, productname);
objDB.AddInParameter(objAdd, "@DESCRIPTION", DbType.String, description);
objDB.AddInParameter(objAdd, "@QUANTITY", DbType.Decimal, quantity);
objDB.AddInParameter(objAdd, "@PRICE", DbType.Decimal, price);
objDB.AddInParameter(objAdd, "@KEYWORDS", DbType.String, keywords);
objDB.AddInParameter(objAdd, "@IMAGE1", DbType.String, image1);
objDB.AddInParameter(objAdd, "@IMAGE2", DbType.String, image2);
objDB.AddInParameter(objAdd, "@IMAGE3", DbType.String, image3);
objDB.AddInParameter(objAdd, "@IMAGE4", DbType.String, image4);
objDB.AddOutParameter(objAdd, "@Stat", DbType.Int16, 16);
objDB.ExecuteNonQuery(objAdd);
status = Convert.ToInt16(objDB.GetParameterValue(objAdd, "@Stat"));
}
catch (Exception ex)
{
objErr.GeneralExceptionHandling(ex, "Website - Post Product", "addNewProductPost", "GENERAL EXCEPTION");
}
return status;
}
开发者ID:pratikmoda,项目名称:SLD,代码行数:35,代码来源:BL_Product.cs
示例15: NoEventBroadcastIfNoEventRegistered
public void NoEventBroadcastIfNoEventRegistered()
{
string connectionString = @"server=(local)\sqlexpress;database=northwind;integrated security=true;";
SqlDatabase db = new SqlDatabase(connectionString);
db.ExecuteNonQuery(CommandType.Text, "Select count(*) from Region");
}
开发者ID:jmeckley,项目名称:Enterprise-Library-5.0,代码行数:7,代码来源:InstrumentationNoListenerEventBroadcastFixture.cs
示例16: BookTicketDAL
public static bool BookTicketDAL(Models.TicketBooking data)
{
SqlDatabase travelMSysDB = new SqlDatabase(ConnString.DBConnectionString);
SqlCommand insertCmmnd = new SqlCommand("INSERT INTO TICKET_BOOKINGS ([Travel_Request_ID],[Ticket_Details],[Booking_Status]) VALUES (@Travel_Request_ID,@Ticket_Details,@Booking_Status)");
insertCmmnd.CommandType = CommandType.Text;
insertCmmnd.Parameters.AddWithValue("@Travel_Request_ID", data.Travel_Request_ID);
insertCmmnd.Parameters.AddWithValue("@Ticket_Details", data.Ticket_Details);
insertCmmnd.Parameters.AddWithValue("@Booking_Status", data.Booking_Status);
int rowsAffected = travelMSysDB.ExecuteNonQuery(insertCmmnd);
Console.Write("rowsAffected " + rowsAffected);
SqlCommand updateCmmnd = new SqlCommand("UPDATE TRAVEL_REQUESTS SET [Request_Status]='P' WHERE [email protected]_Request_ID");
updateCmmnd.CommandType = CommandType.Text;
updateCmmnd.Parameters.AddWithValue("@Travel_Request_ID", data.Travel_Request_ID);
int rowsAffectedTReq = travelMSysDB.ExecuteNonQuery(updateCmmnd);
//two booking records for same travel req issue to be resolved wherever applicable - or just delete the rows when booking cancelled
if (rowsAffected == 1&&rowsAffectedTReq==1)
return true;
return false;
}
开发者ID:liveevil,项目名称:TravelMS,代码行数:26,代码来源:AgentDALayer.cs
示例17: PublicarMensajeSql
public void PublicarMensajeSql(string aplicacion, string error, Exception excepcion)
{
try
{
SqlDatabase baseDedatos = new SqlDatabase(ConfigurationManager.ConnectionStrings["AccesoDual"].ConnectionString);
DbCommand comando = baseDedatos.GetStoredProcCommand("adm.NlayerSP_RegistrarErrorAplicativo");
comando.CommandType = CommandType.StoredProcedure;
string interna = null;
if (excepcion.InnerException != null)
{
interna = excepcion.InnerException.Message;
}
baseDedatos.AddInParameter(comando, "Aplicacion", SqlDbType.NVarChar, aplicacion);
baseDedatos.AddInParameter(comando, "Error", SqlDbType.NVarChar, error);
baseDedatos.AddInParameter(comando, "Excepcion", SqlDbType.NText, excepcion.Message);
baseDedatos.AddInParameter(comando, "Interna", SqlDbType.NText, interna);
baseDedatos.ExecuteNonQuery(comando);
}
catch {}
}
开发者ID:JeyssonRamirez,项目名称:NLayer,代码行数:25,代码来源:ManejarDeLogs.cs
示例18: Unassign
/// <summary>
///
/// </summary>
/// <param name="jobId"></param>
/// <param name="userId"></param>
/// <param name="existing"></param>
/// <returns>0 if user being unassigned has never billed time to the job,
/// 1 if user has billed time to the job</returns>
public static int Unassign(int jobId, int userId, string existing)
{
SqlDatabase db = new SqlDatabase(connString);
DbCommand cmd = null;
if (existing == "delete")
{
cmd = db.GetSqlStringCommand(@" DELETE FROM Allocations WHERE [email protected]_id AND [email protected]_id");
db.AddInParameter(cmd, "@user_id", DbType.Int32, userId);
db.AddInParameter(cmd, "@job_id", DbType.Int32, jobId);
db.ExecuteNonQuery(cmd);
}
else if (existing == "move")
{
MoveAllocations(userId, jobId);
}
int retval = 0;
cmd = db.GetStoredProcCommand("ALOC_Unassign");
db.AddInParameter(cmd, "@job_id", DbType.Int32, jobId);
db.AddInParameter(cmd, "@user_id", DbType.Int32, userId);
object result = db.ExecuteScalar(cmd);
if (result != null && result != DBNull.Value)
retval = Convert.ToInt32(result);
cmd.Dispose();
return retval;
}
开发者ID:the0ther,项目名称:how2www.info,代码行数:34,代码来源:ManageAssignments.cs
示例19: Authenticate
public static UserAuthResult Authenticate(string userName, string password, string providerKey)
{
string Auth_GetUserByCredentials =
@"SELECT u.ID,u.Name,u.Surname,u.Email,u.Password,u.About,u.BirthDate,u.DateCreated,u.LastLogin,u.DateUpdated,ul.LoginProvider
FROM User AS u
INNER JOIN UserLogin AS ul
ON u.ID = ul.UserID
WHERE u.Email = '{1}'
WHERE ul.Providerkey = '{1}'";
string connStr = ConfigurationManager.AppSettings["MasterSQLConnection"];
SqlDatabase db = new SqlDatabase(connStr);
UserAuthResult result = new UserAuthResult();
result.AuthSuccess = false;
User user = new User();
string dbPassword = string.Empty;
try
{
string query = String.Format(Auth_GetUserByCredentials, userName);
using (DbCommand command = db.GetSqlStringCommand(query))
{
using (IDataReader reader = db.ExecuteReader(command))
{
if (reader.Read())
{
//Users.ID,Users.Name,Surname,IsAdmin,IsSuperAdmin,LoginType,Users.ActiveDirectoryDomain,Password
user.ID = int.Parse(reader["ID"].ToString());
user.Password = reader["Password"].ToString();
user.Name = reader["Name"].ToString();
user.Surname = reader["Surname"].ToString();
}
else
{
result.AuthSuccess = false;
result.ErrorMsg = "Username or password is wrong";
}
}
}
}
finally
{
}
if (!string.IsNullOrEmpty(password) && user.ID > 0 && password.Equals(user.Password))
{
result.User = user;
result.AuthSuccess = true;
}
else
{
result.ErrorMsg = "Username or password is wrong";
}
return result;
}
开发者ID:cicimen,项目名称:normalmi,代码行数:59,代码来源:User.cs
示例20: Employees
public static IDataReader Employees(int deptId)
{
SqlDatabase db = new SqlDatabase(connString);
DbCommand command = db.GetSqlStringCommand("SELECT FirstName + ' ' + LastName AS FullName, UserId FROM AllocableUsers WHERE DeptId=" + deptId + " AND Active=1 ORDER BY FullName");
command.CommandType = CommandType.Text;
return db.ExecuteReader(command);
}
开发者ID:the0ther,项目名称:how2www.info,代码行数:8,代码来源:Employee.cs
注:本文中的Microsoft.Practices.EnterpriseLibrary.Data.Sql.SqlDatabase类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论