namespace Dao
|
{
|
using Common;
|
using Model;
|
using Oracle.DataAccess.Client;
|
using System;
|
using System.Collections.Generic;
|
using System.Runtime.InteropServices;
|
using System.Text;
|
|
public class GwApDao : IDisposable
|
{
|
public void Dispose()
|
{
|
}
|
|
public GwAp Get(string apID)
|
{
|
GwAp o = new GwAp();
|
if (!string.IsNullOrEmpty(apID) && !string.Equals("0", apID))
|
{
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_ID", apID) }))
|
{
|
if (reader.Read())
|
{
|
this.ReadInfo(reader, o);
|
return o;
|
}
|
}
|
}
|
return o;
|
}
|
|
public bool IsApIDExits(string apID)
|
{
|
if (string.IsNullOrEmpty(apID) || string.Equals("0", apID))
|
{
|
return true;
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_ID", apID) }))
|
{
|
while (reader.Read())
|
{
|
return true;
|
}
|
}
|
return false;
|
}
|
|
public bool IsNameEixsts(string apName, int apID)
|
{
|
if ((string.IsNullOrEmpty(apName) || string.Equals("0", apName)) || (apID == 0))
|
{
|
return true;
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_NAME=:AP_NAME and AP_ID<>:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_ID", apID), new OracleParameter(":AP_NAME", apName) }))
|
{
|
while (reader.Read())
|
{
|
return true;
|
}
|
}
|
return false;
|
}
|
|
public bool IsPortExits(int port, int apID)
|
{
|
if ((port == 0) || (apID == 0))
|
{
|
return true;
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_PORT=:AP_PORT and AP_ID<>:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_PORT", port), new OracleParameter(":AP_ID", apID) }))
|
{
|
if (reader.Read())
|
{
|
return true;
|
}
|
}
|
return false;
|
}
|
|
public List<GwAp> LoadInfoList()
|
{
|
List<GwAp> list = new List<GwAp>();
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_AP", OracleHelper.Connection))
|
{
|
while (reader.Read())
|
{
|
GwAp o = new GwAp();
|
if (this.ReadInfo(reader, o))
|
{
|
list.Add(o);
|
}
|
}
|
}
|
return list;
|
}
|
|
public List<GwAp> LoadInfoList(out int recordCount, int pageSize, int pageIndex)
|
{
|
List<GwAp> list = new List<GwAp>();
|
recordCount = 0;
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT count(*) as count FROM GW_AP", OracleHelper.Connection))
|
{
|
while (reader.Read())
|
{
|
recordCount = this.ReadCount(reader);
|
}
|
}
|
using (OracleDataReader reader2 = OracleHelper.ExecuteReader(PubConstant.doOracleSql(pageIndex, pageSize, recordCount, "SELECT * FROM GW_AP").ToString(), OracleHelper.Connection))
|
{
|
while (reader2.Read())
|
{
|
GwAp o = new GwAp();
|
if (this.ReadInfo(reader2, o))
|
{
|
list.Add(o);
|
}
|
}
|
}
|
return list;
|
}
|
|
public List<GwAp> LoadInfoList(string ApID, string ApName, string ApPort, out int recordcount, int pageSize, int PageIndex)
|
{
|
List<GwAp> list = new List<GwAp>();
|
recordcount = 0;
|
try
|
{
|
StringBuilder builder = new StringBuilder();
|
builder.Append("from GW_AP where 1=1");
|
OracleParameter[] cmdParms = new OracleParameter[3];
|
if ((ApID != null) && (ApID != ""))
|
{
|
cmdParms[0] = new OracleParameter(":ApID", 0x70);
|
cmdParms[0].Value = ApID;
|
builder.Append(" and AP_ID=:ApID");
|
}
|
if ((ApName != null) && (ApName != ""))
|
{
|
cmdParms[1] = new OracleParameter(":ApName", 0x7e);
|
cmdParms[1].Value = ApName;
|
builder.Append(" and AP_NAME like '%'||:ApName||'%'");
|
}
|
if ((ApPort != null) && (ApPort != ""))
|
{
|
cmdParms[2] = new OracleParameter(":ApPort", 0x70);
|
cmdParms[2].Value = ApPort;
|
builder.Append(" and AP_PORT=:ApPort");
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + builder.ToString(), OracleHelper.Connection, cmdParms))
|
{
|
while (reader.Read())
|
{
|
recordcount = this.ReadCount(reader);
|
}
|
}
|
using (OracleDataReader reader2 = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + builder.ToString()).ToString(), OracleHelper.Connection, cmdParms))
|
{
|
while (reader2.Read())
|
{
|
GwAp o = new GwAp();
|
if (this.ReadInfo(reader2, o))
|
{
|
list.Add(o);
|
}
|
}
|
}
|
}
|
catch (Exception exception)
|
{
|
LogHelper.Error(exception);
|
return list;
|
}
|
return list;
|
}
|
|
private int ReadCount(OracleDataReader reader)
|
{
|
OracleReaderWrapper wrapper = new OracleReaderWrapper(reader);
|
return wrapper.GetInt("count", 0);
|
}
|
|
private bool ReadInfo(OracleDataReader reader, GwAp o)
|
{
|
OracleReaderWrapper wrapper = new OracleReaderWrapper(reader);
|
o.ApID = wrapper.GetInt("AP_ID", 0);
|
o.ApName = wrapper.GetString("AP_NAME", "");
|
o.ApPort = wrapper.GetInt("AP_PORT", 0);
|
o.AccessCode = wrapper.GetString("ACCESS_CODE", "");
|
o.CMSegments = wrapper.GetString("CM_SEGMENTS", "");
|
o.CTSegments = wrapper.GetString("CT_SEGMENTS", "");
|
o.UNSegments = wrapper.GetString("UN_SEGMENTS", "");
|
o.AlarmData = wrapper.GetString("ALARM_SETTING", "");
|
return true;
|
}
|
|
public bool Update(GwAp o)
|
{
|
OracleParameter[] cmdParms = new OracleParameter[] { new OracleParameter(":ApName", o.ApName), new OracleParameter(":ApPort", o.ApPort), new OracleParameter(":ApID", o.ApID), new OracleParameter(":ACCESS_CODE", o.AccessCode), new OracleParameter(":CM_SEGMENTS", o.CMSegments), new OracleParameter(":UN_SEGMENTS", o.UNSegments), new OracleParameter(":CT_SEGMENTS", o.CTSegments), new OracleParameter(":ALARM_SETTING", o.AlarmData) };
|
string sql = "UPDATE GW_AP SET AP_NAME=:APNAME,AP_PORT=:APPORT,ACCESS_CODE=:ACCESS_CODE,CM_SEGMENTS=:CM_SEGMENTS,CT_SEGMENTS=:CT_SEGMENTS,UN_SEGMENTS=:UN_SEGMENTS,ALARM_SETTING=:ALARM_SETTING WHERE AP_ID=:APID";
|
return (OracleHelper.ExecuteSql(sql, OracleHelper.Connection, cmdParms) > 0);
|
}
|
|
public bool UpdateSegments(GwAp o)
|
{
|
OracleParameter[] cmdParms = new OracleParameter[] { new OracleParameter(":CM_SEGMENTS", o.CMSegments), new OracleParameter(":UN_SEGMENTS", o.UNSegments), new OracleParameter(":CT_SEGMENTS", o.CTSegments) };
|
string sql = "UPDATE GW_AP SET CM_SEGMENTS=:CM_SEGMENTS,CT_SEGMENTS=:CT_SEGMENTS,UN_SEGMENTS=:UN_SEGMENTS ";
|
return (OracleHelper.ExecuteSql(sql, OracleHelper.Connection, cmdParms) > 0);
|
}
|
}
|
}
|
|
|
|
|
/*
|
using Common;
|
using Model;
|
using Oracle.DataAccess.Client;
|
using System;
|
using System.Collections.Generic;
|
using System.Data.Common;
|
using System.Text;
|
|
namespace Dao
|
{
|
public class GwApDao : IDisposable
|
{
|
public List<GwAp> LoadInfoList(string ApID, string ApName, string ApPort, out int recordcount, int pageSize, int PageIndex)
|
{
|
List<GwAp> list = new List<GwAp>();
|
recordcount = 0;
|
try
|
{
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("from GW_AP where 1=1");
|
OracleParameter[] oracleParameterArray = new OracleParameter[3];
|
if (ApID != null && ApID != "")
|
{
|
oracleParameterArray[0] = new OracleParameter(":ApID", (OracleDbType) 112);
|
((DbParameter) oracleParameterArray[0]).Value = (object) ApID;
|
stringBuilder.Append(" and AP_ID=:ApID");
|
}
|
if (ApName != null && ApName != "")
|
{
|
oracleParameterArray[1] = new OracleParameter(":ApName", (OracleDbType) 126);
|
((DbParameter) oracleParameterArray[1]).Value = (object) ApName;
|
stringBuilder.Append(" and AP_NAME like '%'||:ApName||'%'");
|
}
|
if (ApPort != null && ApPort != "")
|
{
|
oracleParameterArray[2] = new OracleParameter(":ApPort", (OracleDbType) 112);
|
((DbParameter) oracleParameterArray[2]).Value = (object) ApPort;
|
stringBuilder.Append(" and AP_PORT=:ApPort");
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader) reader).Read())
|
recordcount = this.ReadCount(reader);
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + stringBuilder.ToString()).ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
GwAp o = new GwAp();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex);
|
return list;
|
}
|
return list;
|
}
|
|
public List<GwAp> LoadInfoList()
|
{
|
List<GwAp> list = new List<GwAp>();
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_AP", OracleHelper.Connection))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
GwAp o = new GwAp();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
return list;
|
}
|
|
public bool Update(GwAp o)
|
{
|
return OracleHelper.ExecuteSql("UPDATE GW_AP SET AP_NAME=:APNAME,AP_PORT=:APPORT,ACCESS_CODE=:ACCESS_CODE,CM_SEGMENTS=:CM_SEGMENTS,CT_SEGMENTS=:CT_SEGMENTS,UN_SEGMENTS=:UN_SEGMENTS,ALARM_SETTING=:ALARM_SETTING WHERE AP_ID=:APID", OracleHelper.Connection, new OracleParameter(":ApName", (object) o.ApName), new OracleParameter(":ApPort", (object) o.ApPort), new OracleParameter(":ApID", (object) o.ApID), new OracleParameter(":ACCESS_CODE", (object) o.AccessCode), new OracleParameter(":CM_SEGMENTS", (object) o.CMSegments), new OracleParameter(":UN_SEGMENTS", (object) o.UNSegments), new OracleParameter(":CT_SEGMENTS", (object) o.CTSegments), new OracleParameter(":ALARM_SETTING", (object) o.AlarmData)) > 0;
|
}
|
|
public GwAp Get(string apID)
|
{
|
GwAp o = new GwAp();
|
if (string.IsNullOrEmpty(apID) || string.Equals("0", apID))
|
return o;
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_ID", (object) apID)))
|
{
|
if (((DbDataReader) reader).Read())
|
{
|
this.ReadInfo(reader, o);
|
return o;
|
}
|
}
|
return o;
|
}
|
|
public bool IsApIDExits(string apID)
|
{
|
if (string.IsNullOrEmpty(apID) || string.Equals("0", apID))
|
return true;
|
using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_ID", (object) apID)))
|
{
|
if (((DbDataReader) oracleDataReader).Read())
|
return true;
|
}
|
return false;
|
}
|
|
public bool IsNameEixsts(string apName, int apID)
|
{
|
if (string.IsNullOrEmpty(apName) || string.Equals("0", apName) || apID == 0)
|
return true;
|
using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_NAME=:AP_NAME and AP_ID<>:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_ID", (object) apID), new OracleParameter(":AP_NAME", (object) apName)))
|
{
|
if (((DbDataReader) oracleDataReader).Read())
|
return true;
|
}
|
return false;
|
}
|
|
public bool IsPortExits(int port, int apID)
|
{
|
if (port == 0 || apID == 0)
|
return true;
|
using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_PORT=:AP_PORT and AP_ID<>:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_PORT", (object) port), new OracleParameter(":AP_ID", (object) apID)))
|
{
|
if (((DbDataReader) oracleDataReader).Read())
|
return true;
|
}
|
return false;
|
}
|
|
private bool ReadInfo(OracleDataReader reader, GwAp o)
|
{
|
OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
|
o.ApID = oracleReaderWrapper.GetInt("AP_ID", 0);
|
o.ApName = oracleReaderWrapper.GetString("AP_NAME", "");
|
o.ApPort = oracleReaderWrapper.GetInt("AP_PORT", 0);
|
o.AccessCode = oracleReaderWrapper.GetString("ACCESS_CODE", "");
|
o.CMSegments = oracleReaderWrapper.GetString("CM_SEGMENTS", "");
|
o.CTSegments = oracleReaderWrapper.GetString("CT_SEGMENTS", "");
|
o.UNSegments = oracleReaderWrapper.GetString("UN_SEGMENTS", "");
|
o.AlarmData = oracleReaderWrapper.GetString("ALARM_SETTING", "");
|
return true;
|
}
|
|
private int ReadCount(OracleDataReader reader)
|
{
|
return new OracleReaderWrapper(reader).GetInt("count", 0);
|
}
|
|
public void Dispose()
|
{
|
}
|
}
|
}
|
*/
|
