?? operdatabase.cs
字號(hào):
using System;
using System.Data;
using System.Data.SqlClient;
namespace database
{
/// <summary>
/// OperDatabase 的摘要說明。
/// </summary>
public class SmsDetails
{
public int Sms_ID;
public string Sms_ServiceID;
public int Sms_SeqID;
public string Sms_MsgID;
public int Sms_Fee_UserType;
public string Sms_SPID;
public string Sms_FeeType;
public string Sms_FeeCode;
public string Sms_SPCode;
public string Sms_Dest_Terminal_ID;
public int Sms_Msg_Length;
public string Sms_Msg_Content;
}
public class ErrorDetails
{
public int ID;
public string Information;
}
public class OperDatabase
{
string connstr; // = "data source=(local);initial catalog=sms;persist security info=False;user id=sa;password=123";
SqlConnection conn;
//sendMessage send;
public OperDatabase()
{
//connstr ="data source=A-0283QBDDU7CK6;initial catalog=HSH21;persist security info=False;user id=liuyuxiang;password=5829266";
//connstr = "Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=CMPP;Data Source=HUASHEN";
connstr ="Persist Security Info=False;Initial Catalog=SMS;UID=sa;Data Source=CXT-dev;Packet Size=4096;Workstation ID=CXT-dev;";
// send = new sendMessage();
//connstr = "workstation id=HSH1;packet size=4096;user id=sa;data source=HSH1;persist security info=True;initial catalog=sms;password=123456";
}
public bool InsertMO(int nSeqId,string usMsgId,string sPCode,string sServiceId,string sSrcTel,int uRegister, int usMsgLen, string usMsgContent)
{
try
{
conn = new SqlConnection(connstr);
SqlCommand comm = new SqlCommand("Insert_MO_BACK",conn);
comm.CommandType = CommandType.StoredProcedure;
comm.Parameters.Add("@Sms_SeqID",SqlDbType.Int,4);
comm.Parameters.Add("@Sms_MsgID",SqlDbType.NVarChar,70);
comm.Parameters.Add("@Sms_SPCode",SqlDbType.NVarChar,21);
comm.Parameters.Add("@Sms_ServiceID",SqlDbType.NVarChar,20);
comm.Parameters.Add("@Sms_SrcTel",SqlDbType.NVarChar,32);
comm.Parameters.Add("@Sms_Register",SqlDbType.Int,4);
comm.Parameters.Add("@Sms_MsgLen",SqlDbType.Int,4);
comm.Parameters.Add("@Sms_Content",SqlDbType.NVarChar,70);
comm.Parameters["@Sms_SeqID"].Value = nSeqId;
comm.Parameters["@Sms_MsgID"].Value = usMsgId;
comm.Parameters["@Sms_SPCode"].Value = sPCode;
comm.Parameters["@Sms_ServiceID"].Value = sServiceId;
comm.Parameters["@Sms_SrcTel"].Value = sSrcTel;
comm.Parameters["@Sms_Register"].Value = uRegister;
comm.Parameters["@Sms_MsgLen"].Value = usMsgLen;
comm.Parameters["@Sms_Content"].Value = usMsgContent;
conn.Open();
comm.ExecuteNonQuery();
conn.Close();
conn = new SqlConnection(connstr);
SqlCommand comm1 = new SqlCommand("Insert_MO",conn);
comm1.CommandType = CommandType.StoredProcedure;
comm1.Parameters.Add("@Sms_SeqID",SqlDbType.Int,4);
comm1.Parameters.Add("@Sms_MsgID",SqlDbType.NVarChar,70);
comm1.Parameters.Add("@Sms_SPCode",SqlDbType.NVarChar,21);
comm1.Parameters.Add("@Sms_ServiceID",SqlDbType.NVarChar,20);
comm1.Parameters.Add("@Sms_SrcTel",SqlDbType.NVarChar,32);
comm1.Parameters.Add("@Sms_Register",SqlDbType.Int,4);
comm1.Parameters.Add("@Sms_MsgLen",SqlDbType.Int,4);
comm1.Parameters.Add("@Sms_Content",SqlDbType.NVarChar,70);
comm1.Parameters["@Sms_SeqID"].Value = nSeqId;
comm1.Parameters["@Sms_MsgID"].Value = usMsgId;
comm1.Parameters["@Sms_SPCode"].Value = sPCode;
comm1.Parameters["@Sms_ServiceID"].Value = sServiceId;
comm1.Parameters["@Sms_SrcTel"].Value = sSrcTel;
comm1.Parameters["@Sms_Register"].Value = uRegister;
comm1.Parameters["@Sms_MsgLen"].Value = usMsgLen;
comm1.Parameters["@Sms_Content"].Value = usMsgContent;
conn.Open();
comm1.ExecuteNonQuery();
conn.Close();
return true;
}
catch(Exception e)
{
return false;
//send.Deliever("插入數(shù)據(jù)庫(kù)失敗!"+e.Message);
}
}
public bool InsertError(string message)
{
try
{
conn = new SqlConnection(connstr);
SqlCommand comm = new SqlCommand("Insert_Error",conn);
comm.CommandType = CommandType.StoredProcedure;
comm.Parameters.Add("@Information",SqlDbType.NVarChar,70);
comm.Parameters["@Information"].Value = message;
conn.Open();
comm.ExecuteNonQuery();
conn.Close();
return true;
}
catch(Exception e)
{
return false;
// send.Deliever("插入數(shù)據(jù)庫(kù)失敗!"+e.Message);
}
}
public SmsDetails GetMT()
{
conn = new SqlConnection("Persist Security Info=False;Initial Catalog=SMS;UID=sa;Data Source=CXT-dev;Packet Size=4096;Workstation ID=CXT-dev;");
DataSet dataSet = new DataSet();
conn.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
SqlCommand comm = new SqlCommand("Get_MT",conn);
comm.CommandType =CommandType.StoredProcedure;
sqlDA.SelectCommand =comm;
sqlDA.Fill( dataSet, "SMS" );
conn.Close();
SmsDetails details = new SmsDetails();
// if the record was found, set the properties of the class instance
if (dataSet.Tables[0].Rows.Count > 0)
{
try
{
DataRow rowNews = dataSet.Tables[0].Rows[0];
details.Sms_ID = (int)rowNews["Sms_ID"];
details.Sms_MsgID =rowNews["Sms_MsgID"].ToString();
details.Sms_ServiceID = rowNews["Sms_ServiceID"].ToString();
details.Sms_SPCode = rowNews["Sms_SPCode"].ToString();
details.Sms_Fee_UserType = (int)rowNews["Sms_Fee_UserType"];
details.Sms_SPID = rowNews["Sms_SPID"].ToString();
details.Sms_FeeType = rowNews["Sms_FeeType"].ToString();
details.Sms_FeeCode = rowNews["Sms_FeeCode"].ToString();
details.Sms_Dest_Terminal_ID = rowNews["Sms_Dest_Terminal_Id"].ToString();
details.Sms_Msg_Length = (int)rowNews["Sms_Msg_Length"];
details.Sms_SeqID = (int)rowNews["Sms_SeqID"];
details.Sms_Msg_Content = rowNews["Sms_Msg_Content"].ToString();
}
catch(Exception ex)
{
// send.Deliever("獲得數(shù)據(jù)庫(kù)數(shù)據(jù)轉(zhuǎn)換數(shù)據(jù)失敗!"+ex.Message);
}
}
else
details.Sms_ID =-1;
return details;
}
public ErrorDetails sendError()
{
conn = new SqlConnection(connstr);
DataSet dataSet = new DataSet();
conn.Open();
SqlDataAdapter sqlDA1 = new SqlDataAdapter();
SqlCommand comm = new SqlCommand("Get_Error",conn);
comm.CommandType =CommandType.StoredProcedure;
sqlDA1.SelectCommand =comm;
sqlDA1.Fill(dataSet, "Error" );
conn.Close();
ErrorDetails details = new ErrorDetails();
// if the record was found, set the properties of the class instance
if (dataSet.Tables[0].Rows.Count > 0)
{
try
{
DataRow rowNews = dataSet.Tables[0].Rows[0];
details.ID = (int)rowNews["ID"];
details.Information =rowNews["Information"].ToString();
}
catch(Exception ex)
{
// send.Deliever("獲得數(shù)據(jù)庫(kù)數(shù)據(jù)轉(zhuǎn)換數(shù)據(jù)失敗!"+ex.Message);
}
}
else
details.ID =-1;
return details;
}
/*
public SmsDetails GetMT()
{
try
{
conn = new SqlConnection(connstr);
DataSet dataSet = new DataSet();
conn.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
SqlCommand comm = new SqlCommand("Get_MT",conn);
comm.CommandType =CommandType.StoredProcedure;
sqlDA.SelectCommand =comm;
sqlDA.Fill( dataSet, "SMS" );
conn.Close();
SmsDetails details = new SmsDetails();
// if the record was found, set the properties of the class instance
if (dataSet.Tables[0].Rows.Count > 0)
{
DataRow rowNews = dataSet.Tables[0].Rows[0];
details.Sms_ID = (int)rowNews["Sms_ID"];
details.Sms_ServiceID = rowNews["Sms_ServiceID"].ToString();
details.Sms_SPCode = rowNews["Sms_SPCode"].ToString();
details.Sms_Fee_UserType = (int)rowNews["Sms_Fee_UserType"];
details.Sms_SPID = rowNews["Sms_SPID"].ToString();
details.Sms_FeeType = rowNews["Sms_FeeType"].ToString();
details.Sms_FeeCode = rowNews["Sms_FeeCode"].ToString();
details.Sms_Dest_Terminal_ID = rowNews["Sms_Dest_Terminal_Id"].ToString();
details.Sms_Msg_Length = (int)rowNews["Sms_Msg_Length"];
details.Sms_Msg_Content = rowNews["Sms_Msg_Content"].ToString();
}
return details;
}
catch(DataException e)
{
return null;
}
}
*/
}
}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -