|
|
using System;
|
|
|
using System.IO;
|
|
|
using System.Collections;
|
|
|
using BP.DA;
|
|
|
using System.Data;
|
|
|
using BP.Sys;
|
|
|
using BP.En;
|
|
|
|
|
|
namespace BP.Sys.XML
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// XmlEn 的摘要说明。
|
|
|
/// </summary>
|
|
|
abstract public class XmlEn
|
|
|
{
|
|
|
#region 获取值
|
|
|
private Row _row = null;
|
|
|
public Row Row
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
if (this._row == null)
|
|
|
this._row = new Row();
|
|
|
// throw new Exception("xmlEn 没有被实例化。");
|
|
|
return this._row;
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
this._row = value;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取一个对象
|
|
|
/// </summary>
|
|
|
/// <param name="attrKey"></param>
|
|
|
/// <returns></returns>
|
|
|
public Object GetValByKey(string attrKey)
|
|
|
{
|
|
|
if (this._row == null)
|
|
|
return null;
|
|
|
|
|
|
return this.Row.GetValByKey(attrKey);
|
|
|
}
|
|
|
public int GetValIntByKey(string key)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
return int.Parse(this.GetValByKey(key).ToString().Trim());
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
throw new Exception("key=" + key + "不能向int 类型转换。val=" + this.GetValByKey(key));
|
|
|
}
|
|
|
}
|
|
|
public decimal GetValDecimalByKey(string key)
|
|
|
{
|
|
|
return (decimal)this.GetValByKey(key);
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取一个对象
|
|
|
/// </summary>
|
|
|
/// <param name="attrKey"></param>
|
|
|
/// <returns></returns>
|
|
|
public string GetValStringByKey(string attrKey)
|
|
|
{
|
|
|
if (this._row == null)
|
|
|
return "";
|
|
|
|
|
|
try
|
|
|
{
|
|
|
return this.Row.GetValByKey(attrKey) as string;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception(" @XMLEN Error Attr=[" + attrKey + "], ClassName= " + this.ToString() + " , File =" + this.GetNewEntities.File + " , Error = " + ex.Message);
|
|
|
}
|
|
|
}
|
|
|
public string GetValStringHtmlByKey(string attrKey)
|
|
|
{
|
|
|
return this.GetValStringByKey(attrKey).Replace("\n", "<BR>").Replace(" ", " ");
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取一个对象
|
|
|
/// </summary>
|
|
|
/// <param name="key"></param>
|
|
|
/// <returns></returns>
|
|
|
public bool GetValBoolByKey(string key)
|
|
|
{
|
|
|
string val = this.GetValStringByKey(key);
|
|
|
if (DataType.IsNullOrEmpty(val))
|
|
|
return false;
|
|
|
|
|
|
if (val == "1" || val.ToUpper() == "TRUE")
|
|
|
return true;
|
|
|
else
|
|
|
return false;
|
|
|
}
|
|
|
public void SetVal(string k, object val)
|
|
|
{
|
|
|
this.Row.SetValByKey(k, val);
|
|
|
}
|
|
|
#endregion 获取值
|
|
|
|
|
|
#region 构造函数
|
|
|
/// <summary>
|
|
|
/// 构造函数
|
|
|
/// </summary>
|
|
|
public XmlEn()
|
|
|
{
|
|
|
}
|
|
|
|
|
|
public int RetrieveByPK(string key, string val)
|
|
|
{
|
|
|
XmlEns ens = Cache.GetObj(this.GetNewEntities.ToString(), Depositary.Application) as XmlEns;
|
|
|
if (ens == null)
|
|
|
{
|
|
|
ens = this.GetNewEntities;
|
|
|
ens.RetrieveAll();
|
|
|
//Cache.SetConn(this.GetNewEntities.ToString(), Depositary.Application) as XmlEns;
|
|
|
}
|
|
|
|
|
|
int i = 0;
|
|
|
foreach (XmlEn en in ens)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key).Equals(val))
|
|
|
{
|
|
|
this.Row = en.Row;
|
|
|
i++;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (i == 1)
|
|
|
return 1;
|
|
|
|
|
|
if (i > 1)
|
|
|
{
|
|
|
// SystemConfig.DoClearCache();
|
|
|
throw new Exception("@XML=[" + this.ToString() + "]中PK=" + val + "不唯一...");
|
|
|
}
|
|
|
return 0;
|
|
|
}
|
|
|
public int Retrieve(string key, string val, string key1,string val1)
|
|
|
{
|
|
|
XmlEns ens = Cache.GetObj(this.GetNewEntities.ToString(), Depositary.Application) as XmlEns;
|
|
|
if (ens == null)
|
|
|
{
|
|
|
ens = this.GetNewEntities;
|
|
|
ens.RetrieveAll();
|
|
|
}
|
|
|
|
|
|
int i = 0;
|
|
|
foreach (XmlEn en in ens)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key) == val && en.GetValStringByKey(key1)==val1 )
|
|
|
{
|
|
|
this.Row = en.Row;
|
|
|
i++;
|
|
|
}
|
|
|
}
|
|
|
if (i == 1)
|
|
|
return 1;
|
|
|
|
|
|
return 0;
|
|
|
}
|
|
|
#endregion 构造函数
|
|
|
|
|
|
#region 需要子类实现的方法
|
|
|
public abstract XmlEns GetNewEntities { get; }
|
|
|
#endregion 需要子类实现的方法
|
|
|
}
|
|
|
abstract public class XmlEnNoName:XmlEn
|
|
|
{
|
|
|
public string No
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStringByKey("No");
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
this.SetVal("No", value);
|
|
|
}
|
|
|
}
|
|
|
public string Name
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStringByKey("Name");
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
this.SetVal("Name", value);
|
|
|
}
|
|
|
}
|
|
|
public XmlEnNoName()
|
|
|
{
|
|
|
}
|
|
|
public XmlEnNoName(string no)
|
|
|
{
|
|
|
int i= this.RetrieveByPK("No", no);
|
|
|
if (i == 0)
|
|
|
throw new Exception("@没有查询到 No ="+no+" XML数据.");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// XmlEn 的摘要说明。
|
|
|
/// </summary>
|
|
|
abstract public class XmlEns:System.Collections.CollectionBase
|
|
|
{
|
|
|
public int LoadXmlFile(string file)
|
|
|
{
|
|
|
return LoadXmlFile(file, this.TableName);
|
|
|
}
|
|
|
public int LoadXmlFile(string file, string table)
|
|
|
{
|
|
|
DataSet ds = new DataSet();
|
|
|
ds.ReadXml(file);
|
|
|
DataTable dt = ds.Tables[table];
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
XmlEn en = this.GetNewEntity;
|
|
|
en.Row = new Row();
|
|
|
en.Row.LoadDataTable(dt, dr);
|
|
|
this.Add(en);
|
|
|
}
|
|
|
return dt.Rows.Count;
|
|
|
}
|
|
|
public bool Contine(string key, string val)
|
|
|
{
|
|
|
foreach (XmlEn en in this)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key) == val)
|
|
|
return true;
|
|
|
}
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
#region 构造
|
|
|
/// <summary>
|
|
|
/// 构造
|
|
|
/// </summary>
|
|
|
public XmlEns()
|
|
|
{
|
|
|
|
|
|
}
|
|
|
#endregion 构造
|
|
|
|
|
|
#region 查询方法
|
|
|
public string Tname
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
string tname = this.File.Replace(".TXT", "").Replace(".txt", "");
|
|
|
tname = tname.Substring(tname.LastIndexOf("/") + 1) + this.TableName + "_X";
|
|
|
return tname;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
private DataTable GetTableTxts(FileInfo[] fis)
|
|
|
{
|
|
|
DataTable cdt = Cache.GetObj(this.Tname, Depositary.Application) as DataTable;
|
|
|
if (cdt != null)
|
|
|
return cdt;
|
|
|
|
|
|
DataTable dt = new DataTable(this.TableName);
|
|
|
foreach (FileInfo fi in fis)
|
|
|
{
|
|
|
dt = GetTableTxt(dt, fi);
|
|
|
}
|
|
|
|
|
|
Cache.AddObj(this.Tname,
|
|
|
Depositary.Application, dt);
|
|
|
return dt;
|
|
|
}
|
|
|
private DataTable GetTableTxt()
|
|
|
{
|
|
|
DataTable cdt = Cache.GetObj(this.Tname, Depositary.Application) as DataTable;
|
|
|
if (cdt != null)
|
|
|
return cdt;
|
|
|
|
|
|
DataTable dt = new DataTable(this.TableName);
|
|
|
FileInfo fi = new FileInfo(this.File);
|
|
|
dt = GetTableTxt(dt, fi);
|
|
|
|
|
|
Cache.AddObj(this.Tname,
|
|
|
Depositary.Application, dt);
|
|
|
return dt;
|
|
|
}
|
|
|
private DataTable GetTableTxt(DataTable dt,FileInfo file)
|
|
|
{
|
|
|
StreamReader sr = new StreamReader(file.FullName, System.Text.ASCIIEncoding.GetEncoding("GB2312"));
|
|
|
Hashtable ht = new Hashtable();
|
|
|
string key = "";
|
|
|
string val = "";
|
|
|
while (true)
|
|
|
{
|
|
|
if (sr.EndOfStream)
|
|
|
break;
|
|
|
string lin = sr.ReadLine();
|
|
|
if (lin == "" || lin == null)
|
|
|
continue;
|
|
|
|
|
|
|
|
|
if (lin.IndexOf("*") == 0)
|
|
|
{
|
|
|
/* 遇到注释文件 */
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
if (lin.IndexOf("=") == 0 || sr.EndOfStream)
|
|
|
{
|
|
|
/* 约定的行记录, 开始以 = 开始就认为是一个新的记录。 */
|
|
|
// 处理表结构。
|
|
|
foreach (string ojbkey in ht.Keys)
|
|
|
{
|
|
|
if (dt.Columns.Contains(ojbkey) == false)
|
|
|
{
|
|
|
dt.Columns.Add(new DataColumn(ojbkey, typeof(string)));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
DataRow dr = dt.NewRow();
|
|
|
foreach (string ojbkey in ht.Keys)
|
|
|
{
|
|
|
dr[ojbkey] = ht[ojbkey];
|
|
|
}
|
|
|
|
|
|
if (ht.Keys.Count > 1)
|
|
|
dt.Rows.Add(dr);
|
|
|
|
|
|
|
|
|
ht.Clear(); // clear hashtable.
|
|
|
if (sr.EndOfStream)
|
|
|
break;
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
int idx = lin.IndexOf("=");
|
|
|
if (idx == -1)
|
|
|
{
|
|
|
throw new Exception(this.File + "@不符合规则 key =val 的规则。");
|
|
|
}
|
|
|
|
|
|
key = lin.Substring(0, idx);
|
|
|
if (key == "")
|
|
|
continue;
|
|
|
|
|
|
val = lin.Substring(idx + 1);
|
|
|
ht.Add(key, val);
|
|
|
}
|
|
|
|
|
|
|
|
|
return dt;
|
|
|
}
|
|
|
public DataTable GetTable()
|
|
|
{
|
|
|
DataTable cdt = Cache.GetObj(this.Tname, Depositary.Application) as DataTable;
|
|
|
if (cdt != null)
|
|
|
return cdt;
|
|
|
|
|
|
if (this.File.ToLower().IndexOf(".txt") > 0)
|
|
|
{
|
|
|
return this.GetTableTxt();
|
|
|
}
|
|
|
|
|
|
if (this.File.ToLower().IndexOf(".xml") > 0)
|
|
|
{
|
|
|
DataSet ds1 = new DataSet();
|
|
|
ds1.ReadXml(this.File);
|
|
|
DataTable mdt = ds1.Tables[this.TableName];
|
|
|
if (mdt == null)
|
|
|
mdt = new DataTable();
|
|
|
|
|
|
Cache.AddObj(this.Tname,
|
|
|
Depositary.Application, mdt);
|
|
|
|
|
|
return ds1.Tables[this.TableName];
|
|
|
}
|
|
|
|
|
|
/* 说明这个是目录 */
|
|
|
System.IO.DirectoryInfo di = new System.IO.DirectoryInfo(this.File);
|
|
|
if (di.Exists == false)
|
|
|
throw new Exception("文件不存在:" + this.File);
|
|
|
|
|
|
FileInfo[] fis = di.GetFiles("*.xml");
|
|
|
if (fis.Length == 0)
|
|
|
{
|
|
|
fis = di.GetFiles("*.txt");
|
|
|
return this.GetTableTxts(fis);
|
|
|
}
|
|
|
|
|
|
DataTable dt = new DataTable(this.TableName);
|
|
|
if (fis.Length == 0)
|
|
|
return dt;
|
|
|
|
|
|
DataTable tempDT = new DataTable();
|
|
|
foreach (FileInfo fi in fis)
|
|
|
{
|
|
|
|
|
|
DataSet ds = new DataSet("myds");
|
|
|
try
|
|
|
{
|
|
|
ds.ReadXml(this.File + fi.Name);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("读取文件:" + fi.Name + "错误。Exception=" + ex.Message);
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
//ds.
|
|
|
if (dt.Columns.Count == 0)
|
|
|
{
|
|
|
/* 如果表还是空的，没有任何结构。*/
|
|
|
try
|
|
|
{
|
|
|
dt = ds.Tables[this.TableName];
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("可能是没有在" + fi.Name + "文件中找到表:" + this.TableName + " exception=" + ex.Message);
|
|
|
}
|
|
|
tempDT = dt.Clone();
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
DataTable mydt = ds.Tables[this.TableName];
|
|
|
if (mydt == null)
|
|
|
throw new Exception("无此表:" + this.TableName);
|
|
|
|
|
|
if (mydt.Rows.Count == 0)
|
|
|
continue;
|
|
|
|
|
|
foreach (DataRow mydr in mydt.Rows)
|
|
|
{
|
|
|
//dt.ImportRow(mydr);
|
|
|
DataRow dr = dt.NewRow();
|
|
|
|
|
|
foreach (DataColumn dc in tempDT.Columns)
|
|
|
{
|
|
|
//string "sd".Clone();
|
|
|
if (dc.ColumnName.IndexOf("_Id") != -1)
|
|
|
continue;
|
|
|
|
|
|
try
|
|
|
{
|
|
|
object obj = mydr[dc.ColumnName];
|
|
|
dr[dc.ColumnName] = obj;
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("xml 配置错误，多个文件中的属性不对称。" + ex.Message);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
dt.Rows.Add(dr);
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("获取数据出现错误:fileName=" + fi.Name + " clasName=" + this.ToString() + " MoreInfo=" + ex.Message);
|
|
|
}
|
|
|
}
|
|
|
Cache.AddObj(this.Tname,
|
|
|
Depositary.Application,
|
|
|
dt);
|
|
|
return dt;
|
|
|
}
|
|
|
public virtual int RetrieveAllFromDBSource()
|
|
|
{
|
|
|
Cache.RemoveObj(this.Tname);
|
|
|
return this.RetrieveAll();
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 装载XML
|
|
|
/// </summary>
|
|
|
public virtual int RetrieveAll()
|
|
|
{
|
|
|
this.Clear(); // 清所有的信息。
|
|
|
XmlEns ens = Cache.GetObj(this.ToString(), Depositary.Application) as XmlEns;
|
|
|
if (ens != null)
|
|
|
{
|
|
|
foreach (XmlEn en in ens)
|
|
|
this.Add(en);
|
|
|
return ens.Count;
|
|
|
}
|
|
|
|
|
|
// 从内存中找。
|
|
|
DataTable dt = this.GetTable();
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
XmlEn en = this.GetNewEntity;
|
|
|
en.Row = new Row();
|
|
|
en.Row.LoadDataTable(dt, dr);
|
|
|
this.Add(en);
|
|
|
}
|
|
|
|
|
|
Cache.AddObj(this.ToString(), Depositary.Application, this);
|
|
|
return dt.Rows.Count;
|
|
|
}
|
|
|
public void FullEnToCache(string pk)
|
|
|
{
|
|
|
this.RetrieveAll();
|
|
|
XmlEn myen = this.GetNewEntity;
|
|
|
foreach (XmlEn en in this)
|
|
|
{
|
|
|
Cache.AddObj(myen.ToString() + en.GetValByKey(pk),
|
|
|
Depositary.Application, en);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public int RetrieveByLength(string key, int len )
|
|
|
{
|
|
|
this.Clear(); //清所有的信息
|
|
|
DataTable dt = this.GetTable();
|
|
|
int i = 0;
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
if (dr[key].ToString().Length == len )
|
|
|
{
|
|
|
XmlEn en = this.GetNewEntity;
|
|
|
en.Row = new Row();
|
|
|
en.Row.LoadDataTable(dt, dr);
|
|
|
this.Add(en);
|
|
|
i++;
|
|
|
}
|
|
|
}
|
|
|
return i;
|
|
|
}
|
|
|
public int Retrieve(string key, object val)
|
|
|
{
|
|
|
return RetrieveBy(key,val);
|
|
|
}
|
|
|
public int Retrieve(string key, object val, string key1, string val1)
|
|
|
{
|
|
|
this.Clear(); //清所有的信息
|
|
|
DataTable dt = this.GetTable();
|
|
|
if (dt == null)
|
|
|
throw new Exception("@错误：类" + this.GetNewEntity.ToString() + " File= " + this.File + " Table=" + this.TableName + " ，没有取到数据。");
|
|
|
|
|
|
int i = 0;
|
|
|
try
|
|
|
{
|
|
|
foreach (DataRow dr in dt.Rows)
|
|
|
{
|
|
|
if (dr[key].ToString() == val.ToString() && dr[key1].ToString() == val1)
|
|
|
{
|
|
|
XmlEn en = this.GetNewEntity;
|
|
|
en.Row = new Row();
|
|
|
en.Row.LoadDataTable(dt, dr);
|
|
|
this.Add(en);
|
|
|
i++;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
|
|
throw new Exception("@装载错误:file="+this.File+" xml:"+this.ToString()+"Err:"+ex.Message);
|
|
|
}
|
|
|
return i;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 按照键值查询
|
|
|
/// </summary>
|
|
|
/// <param name="key">要查询的健</param>
|
|
|
/// <param name="val">值</param>
|
|
|
/// <returns>返回查询的个数</returns>
|
|
|
public int RetrieveBy(string key, object val)
|
|
|
{
|
|
|
if (val == null)
|
|
|
return 0;
|
|
|
|
|
|
this.Clear(); //清所有的信息
|
|
|
DataTable dt = this.GetTable();
|
|
|
if (dt == null)
|
|
|
throw new Exception("@错误：类"+this.GetNewEntity.ToString()+" File= "+this.File +" Table="+this.TableName +" ，没有取到数据。");
|
|
|
|
|
|
int i=0;
|
|
|
foreach(DataRow dr in dt.Rows)
|
|
|
{
|
|
|
if ( dr[key].ToString() == val.ToString())
|
|
|
{
|
|
|
XmlEn en =this.GetNewEntity;
|
|
|
en.Row= new Row();
|
|
|
en.Row.LoadDataTable(dt, dr);
|
|
|
this.Add(en);
|
|
|
i++;
|
|
|
}
|
|
|
}
|
|
|
return i;
|
|
|
}
|
|
|
|
|
|
public int RetrieveBy(string key, object val, string orderByAttr)
|
|
|
{
|
|
|
DataTable dt = this.GetTable() ;
|
|
|
DataView dv =new DataView(dt, orderByAttr,orderByAttr,DataViewRowState.Unchanged);
|
|
|
|
|
|
this.Clear(); //清所有的信息.
|
|
|
int i=0;
|
|
|
foreach(DataRow dr in dt.Rows)
|
|
|
{
|
|
|
if (dr[key].ToString() == val.ToString())
|
|
|
{
|
|
|
XmlEn en = this.GetNewEntity;
|
|
|
en.Row = new Row();
|
|
|
en.Row.LoadDataTable(dt, dr);
|
|
|
this.Add(en);
|
|
|
i++;
|
|
|
}
|
|
|
}
|
|
|
return i;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 公共方法
|
|
|
public XmlEn Find(string key, object val)
|
|
|
{
|
|
|
foreach(XmlEn en in this)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key)==val.ToString())
|
|
|
return en;
|
|
|
}
|
|
|
return null;
|
|
|
|
|
|
}
|
|
|
public bool ItIsExits(string key, object val)
|
|
|
{
|
|
|
foreach(XmlEn en in this)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key)==val.ToString())
|
|
|
return true;
|
|
|
}
|
|
|
return false;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
#region 增加 便利访问
|
|
|
public XmlEn GetEnByKey(string key,string val)
|
|
|
{
|
|
|
foreach(XmlEn en in this)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key) ==val)
|
|
|
return en;
|
|
|
}
|
|
|
return null;
|
|
|
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 根据位置取得数据
|
|
|
/// </summary>
|
|
|
public XmlEn this[int index]
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return (XmlEn)this.InnerList[index];
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取数据
|
|
|
/// </summary>
|
|
|
public XmlEn this[string key, string val]
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
foreach(XmlEn en in this)
|
|
|
{
|
|
|
if (en.GetValStringByKey(key)==val)
|
|
|
return en;
|
|
|
}
|
|
|
throw new Exception("在["+this.TableName+","+this.File+","+this.ToString()+"]没有找到key="+key+", val="+val+"的实例。");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 增加一个xml en to Ens.
|
|
|
/// </summary>
|
|
|
/// <param name="entity"></param>
|
|
|
/// <returns></returns>
|
|
|
public virtual int Add(XmlEn entity)
|
|
|
{
|
|
|
return this.InnerList.Add(entity);
|
|
|
}
|
|
|
public virtual int Add(XmlEns ens)
|
|
|
{
|
|
|
if (ens == null)
|
|
|
return 0;
|
|
|
|
|
|
foreach (XmlEn en in ens)
|
|
|
{
|
|
|
this.InnerList.Add(en);
|
|
|
}
|
|
|
return ens.Count;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 与 entities 接口
|
|
|
/// <summary>
|
|
|
/// 把数据装入一个实例集合中（把xml数据装入物理表中）
|
|
|
/// </summary>
|
|
|
/// <param name="ens">实体集合</param>
|
|
|
public void FillXmlDataIntoEntities(Entities ens)
|
|
|
{
|
|
|
this.RetrieveAll(); // 查询出来全部的数据。
|
|
|
Entity en1 = ens.GetNewEntity;
|
|
|
|
|
|
string[] pks = en1.PKs;
|
|
|
foreach(XmlEn xmlen in this)
|
|
|
{
|
|
|
|
|
|
Entity en = ens.GetNewEntity;
|
|
|
foreach(string pk in pks)
|
|
|
{
|
|
|
object obj = xmlen.GetValByKey(pk);
|
|
|
en.SetValByKey(pk, obj);
|
|
|
}
|
|
|
|
|
|
try
|
|
|
{
|
|
|
en.RetrieveFromDBSources();
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
|
|
en.CheckPhysicsTable();
|
|
|
BP.DA.Log.DebugWriteError(ex.Message);
|
|
|
}
|
|
|
|
|
|
|
|
|
foreach(string s in xmlen.Row.Keys)
|
|
|
{
|
|
|
object obj = xmlen.GetValByKey(s);
|
|
|
if (obj==null )
|
|
|
continue;
|
|
|
if (obj.ToString()=="")
|
|
|
continue;
|
|
|
if (obj.ToString()=="None")
|
|
|
continue;
|
|
|
if (obj==DBNull.Value)
|
|
|
continue;
|
|
|
en.SetValByKey(s, obj);
|
|
|
}
|
|
|
en.Save();
|
|
|
}
|
|
|
}
|
|
|
public void FillXmlDataIntoEntities()
|
|
|
{
|
|
|
if (this.RefEns==null)
|
|
|
return ;
|
|
|
this.FillXmlDataIntoEntities(this.RefEns);
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
#region 子类实现xml 信息的描述.
|
|
|
public abstract XmlEn GetNewEntity{get;}
|
|
|
/// <summary>
|
|
|
/// 获取它所在的xml file 位置.
|
|
|
/// </summary>
|
|
|
public abstract string File
|
|
|
{
|
|
|
get;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 物理表名称(可能一个xml文件中有n个Table.)
|
|
|
/// </summary>
|
|
|
public abstract string TableName
|
|
|
{
|
|
|
get;
|
|
|
}
|
|
|
public abstract Entities RefEns
|
|
|
{
|
|
|
get;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
public DataTable ToDataTable()
|
|
|
{
|
|
|
DataTable dt = new DataTable(this.TableName);
|
|
|
|
|
|
if (this.Count == 0)
|
|
|
return dt;
|
|
|
|
|
|
XmlEn en = this[0] as XmlEn;
|
|
|
Row r = en.Row;
|
|
|
foreach (string key in r.Keys)
|
|
|
{
|
|
|
dt.Columns.Add(key, typeof(string));
|
|
|
}
|
|
|
|
|
|
foreach (XmlEn en1 in this)
|
|
|
{
|
|
|
DataRow dr = dt.NewRow();
|
|
|
foreach (string key in r.Keys)
|
|
|
{
|
|
|
dr[key] = en1.GetValStringByKey(key);
|
|
|
}
|
|
|
dt.Rows.Add(dr);
|
|
|
}
|
|
|
|
|
|
return dt;
|
|
|
}
|
|
|
}
|
|
|
}
|