C#中如何定义数据库操作类，并调用？
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了C#中如何定义数据库操作类，并调用？相关的知识，希望对你有一定的参考价值。
麻烦给个例子，最好是完整的源码，有注释的，谢谢各位大虾。
就30分了，全给
using System;
using System.Collections.Generic;
using System.Text;
using System.Data.OleDb;
using System.Configuration;
using System.Data;
namespace AutoEmailSender
/// <summary>
/// 数据库交互类
/// </summary>
public class DB
/// <summary>
/// 获得数据库连接
/// </summary>
/// <returns></returns>
public static OleDbConnection GetDBConnection()
return new OleDbConnection(ConfigurationManager.AppSettings["ConnectString"]);
/// <summary>
/// 查询结果集
/// </summary>
/// <param name="sql">执行语句</param>
/// <returns>返回一个DataTable对象</returns>
public static DataTable ExecuteDataTable(string sql)
using (OleDbConnection con = GetDBConnection())
OleDbCommand cmd = new OleDbCommand(sql, con);
return ExecuteDataTable(cmd);
/// <summary>
/// 查询结果集
/// </summary>
/// <param name="cmd">执行语句的OleDbCommand命令</param>
/// <returns>返回一个DataTable对象</returns>
public static DataTable ExecuteDataTable(OleDbCommand cmd)
DataSet ds = new DataSet();
using (OleDbDataAdapter da = new OleDbDataAdapter(cmd))
try
da.Fill(ds);
catch (Exception e)
throw e;
if (ds.Tables.Count > 0)
ds.Tables[0].DefaultView.RowStateFilter = DataViewRowState.Unchanged | DataViewRowState.Added | DataViewRowState.ModifiedCurrent | DataViewRowState.Deleted;
return ds.Tables[0];
else
return null;
/// <summary>
/// 执行查询，并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。
/// </summary>
/// <param name="sql">查询语句</param>
/// <returns>返回结果集中第一行的第一列的object值</returns>
public static object ExecuteScalar(string sql)
using (OleDbConnection con = GetDBConnection())
OleDbCommand cmd = new OleDbCommand(sql, con);
return ExecuteScalar(cmd);
/// <summary>
/// 执行查询，并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。
/// </summary>
/// <param name="cmd">查询命令</param>
/// <returns>返回结果集中第一行的第一列的object值</returns>
public static object ExecuteScalar(OleDbCommand cmd)
try
cmd.Connection.Open();
object obj = cmd.ExecuteScalar();
cmd.Connection.Close();
return obj;
catch (Exception error)
cmd.Connection.Close();
throw error;
/// <summary>
/// 更新数据集
/// </summary>
/// <param name="dt">要更新的数据集</param>
/// <param name="insertCmd">插入SQL语句</param>
/// <param name="updateCmd">更新SQL语句</param>
/// <param name="deleteCmd">删除SQL语句</param>
/// <returns></returns>
public static int UpdateDataSet(DataTable dt, OleDbCommand insertCmd, OleDbCommand updateCmd, OleDbCommand deleteCmd)
using (OleDbDataAdapter da = new OleDbDataAdapter())
da.InsertCommand = insertCmd;
da.UpdateCommand = updateCmd;
da.DeleteCommand = deleteCmd;
//da.UpdateBatchSize = 0; //UpdateBatchSize:指定可在一次批处理中执行的命令的数量,在Access不被支持。0:批大小没有限制。1:禁用批量更新。>1:更改是使用 UpdateBatchSize 操作的批处理一次性发送的。
da.InsertCommand.UpdatedRowSource = UpdateRowSource.None;
da.UpdateCommand.UpdatedRowSource = UpdateRowSource.None;
da.DeleteCommand.UpdatedRowSource = UpdateRowSource.None;
try
int row = da.Update(dt);
return row;
catch (Exception e)
throw e;
/// <summary>
/// 返回一个查询语句执行结果的表结构
/// </summary>
/// <param name="sql">查询语句,不支持复杂SQL</param>
/// <returns></returns>
public static DataTable GetTableSchema(string sql)
sql = sql.ToUpper();
DataTable dt = null;
using (OleDbConnection con = GetDBConnection())
OleDbCommand cmd = new OleDbCommand(sql, con);
con.Open();
using (OleDbDataReader dr = cmd.ExecuteReader(CommandBehavior.KeyInfo | CommandBehavior.SchemaOnly | CommandBehavior.CloseConnection))
dt = dr.GetSchemaTable();
return dt;
/// <summary>
/// 根据输入的查询语句自动生成插入,更新,删除命令
/// </summary>
/// <param name="sql">查询语句</param>
/// <param name="insertCmd">插入命令</param>
/// <param name="updateCmd">更新命令</param>
/// <param name="deleteCmd">删除命令</param>
public static void GenerateUpdateSQL(string sql, OleDbCommand insertCmd, OleDbCommand updateCmd, OleDbCommand deleteCmd)
sql = sql.ToUpper();
DataTable dt = GetTableSchema(sql);
string tableName = dt.Rows[0]["BaseTableName"].ToString();
List<OleDbParameter> updatePrimarykeys = new List<OleDbParameter>();//主键参数集合
List<OleDbParameter> deletePrimarykeys = new List<OleDbParameter>();//主键参数集合,因为不能同时被OleDbCommand个命令引用,所以多申明一个
List<OleDbParameter> insertFields = new List<OleDbParameter>();//字段参数集合
List<OleDbParameter> updateFields = new List<OleDbParameter>();//字段参数集合
string columns = string.Empty, values = "", set = "", where = "";
foreach (DataRow dr in dt.Rows)
if (dr["IsAutoIncrement"].ToString().Equals("False"))
insertFields.Add(new OleDbParameter("@" + dr["BaseColumnName"].ToString(),
(OleDbType)dr["ProviderType"],
Convert.ToInt32(dr["ColumnSize"]),
dr["BaseColumnName"].ToString()));
updateFields.Add(new OleDbParameter("@" + dr["BaseColumnName"].ToString(),
(OleDbType)dr["ProviderType"],
Convert.ToInt32(dr["ColumnSize"]),
dr["BaseColumnName"].ToString()));
if (!string.IsNullOrEmpty(columns))
columns += ",";
columns += dr["BaseColumnName"].ToString();
if (!string.IsNullOrEmpty(values))
values += ",";
values += "@" + dr["BaseColumnName"].ToString();
if (!string.IsNullOrEmpty(set))
set += ",";
set += dr["BaseColumnName"].ToString() + "=@" + dr["BaseColumnName"].ToString();
if (dr["IsKey"].ToString().Equals("True"))
updatePrimarykeys.Add(new OleDbParameter("@OLD_" + dr["BaseColumnName"].ToString(),
(OleDbType)dr["ProviderType"],
Convert.ToInt32(dr["ColumnSize"]),
ParameterDirection.Input,
Convert.ToBoolean(dr["AllowDBNull"]),
Convert.ToByte(dr["NumericScale"]),
Convert.ToByte(dr["NumericPrecision"]),
dr["BaseColumnName"].ToString(), DataRowVersion.Original, null));
deletePrimarykeys.Add(new OleDbParameter("@OLD_" + dr["BaseColumnName"].ToString(),
(OleDbType)dr["ProviderType"],
Convert.ToInt32(dr["ColumnSize"]),
ParameterDirection.Input,
Convert.ToBoolean(dr["AllowDBNull"]),
Convert.ToByte(dr["NumericScale"]),
Convert.ToByte(dr["NumericPrecision"]),
dr["BaseColumnName"].ToString(), DataRowVersion.Original, null));
if (!string.IsNullOrEmpty(where))
where += " and ";
where += dr["BaseColumnName"].ToString() + "=@OLD_" + dr["BaseColumnName"].ToString();
insertCmd.CommandText = string.Format("insert into 0 (1) values (2)", tableName, columns, values);
updateCmd.CommandText = string.Format("update 0 set 1 where 2", tableName, set, where);
deleteCmd.CommandText = string.Format("delete from 0 where 1", tableName, where);
insertCmd.Connection = GetDBConnection();
updateCmd.Connection = GetDBConnection();
deleteCmd.Connection = GetDBConnection();
foreach (OleDbParameter pa in insertFields)
insertCmd.Parameters.Add(pa);
foreach (OleDbParameter pa in updateFields)
updateCmd.Parameters.Add(pa);
foreach (OleDbParameter pa in updatePrimarykeys)
updateCmd.Parameters.Add(pa);
foreach (OleDbParameter pa in deletePrimarykeys)
deleteCmd.Parameters.Add(pa);
本回答被提问者采纳 参考技术B 1，连接字符串：表示数据库是什么，密码是什么，用户名是什么
2，查询，修改，添加，删除命令
3，数据库函数调用
4，得出结果
给你一个例子如下
public bool Insert(Device.Transmitter transmitter)
string sql = "Insert Into Device (SerialNumber,Address,CommunicationModule,PhoneNumber,InitInfo) Values (@SerialNumber,@Address,@CommunicationModule,@PhoneNumber,@InitInfo)";
OleDbParameter[] param = new OleDbParameter[5];
param[0] = new OleDbParameter("SerialNumber", OleDbType.VarChar, 10);
param[0].Value = transmitter.SerialNumber;
param[1] = new OleDbParameter("Address", OleDbType.VarChar, 50);
param[1].Value = transmitter.Address;
param[2] = new OleDbParameter("CommunicationModule", OleDbType.Integer);
param[2].Value = transmitter.CommunicationModule;
param[3] = new OleDbParameter("PhoneNumber", OleDbType.VarChar, 20);
param[3].Value = transmitter.PhoneNumber;
param[4] = new OleDbParameter("InitInfo", OleDbType.VarChar, 100);
param[4].Value = transmitter.InitInfo;
int count=AccessDB.ExecuteNonQuery(AccessDB.ConnectionString, System.Data.CommandType.Text, sql, param);
return Convert.ToBoolean(count);
/// <summary>
/// Execute a SqlCommand (that returns no resultset) against the database specified in the connection string
/// using the provided parameters.
/// </summary>
/// <remarks>
/// e.g.:
/// int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "PublishOrders", new OleDbParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString">a valid connection string for a OleDbConnection</param>
/// <param name="commandType">the CommandType (stored procedure, text, etc.)</param>
/// <param name="commandText">the stored procedure name or T-SQL command</param>
/// <param name="commandParameters">an array of SqlParamters used to execute the command</param>
/// <returns>an int representing the number of rows affected by the command</returns>
public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params OleDbParameter[] commandParameters)
OleDbCommand cmd = new OleDbCommand();
using (OleDbConnection conn = new OleDbConnection(connectionString))
try
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
cmd.Dispose();
return val;
catch
conn.Close();
throw;
参考技术C 要源码是吗？这个给你。
虽然是在网上Ctrl+C/Ctrl+V来的，但辛苦搜索了半天，希望
对楼主有所帮助吧==========================================================
using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb;
namespace GuestBook
/// <summary>
/// DbControl 的摘要描述。
/// </summary>
public class DbControl:Classes.DataBaseType.DbOpen
//类成员定义。
private int record_total = 0;
protected string DBTYPE,SQL_SELECT;
protected SqlConnection sqlConn;
protected OleDbConnection oleConn;
protected SqlCommand sqlCmd;
protected OleDbCommand oleCmd;
protected DataSet ds = new DataSet();
public int RecordTotal
get
switch (DBTYPE)
case "SQL":
sqlCmd.Cancel();
sqlCmd.CommandText = SQL_SELECT;
SqlDataReader sqlDr;
sqlDr = sqlCmd.ExecuteReader();
while (sqlDr.Read())
record_total++;
sqlDr.Close();
break;
case "OLE":
oleCmd.Cancel();
oleCmd.CommandText = SQL_SELECT;
OleDbDataReader oleDr;
oleDr = oleCmd.ExecuteReader();
while (oleDr.Read())
record_total++;
oleDr.Close();
break;
return record_total;
public DbControl(string dbType,string dbName)
//重载构造函数。
DBTYPE = dbType.ToUpper();
switch (dbType.ToUpper())
case "SQL":
sqlConn = this.SqlConnect(dbName);
oleConn.Close();
oleConn.Dispose();
break;
case "OLE":
oleConn = this.OleConnect(dbName);
oleConn.Close();
oleConn.Dispose();
break;
public DbControl():base()
//
// TODO: 在这里加入建构函式的程式码
//
public void Open(string dbType,string dbName)
//数据库文件打开。
DBTYPE = dbType.ToUpper();
switch (dbType.ToUpper())
case "SQL":
sqlConn = this.SqlConnect(dbName);
break;
case "OLE":
oleConn = this.OleConnect(dbName);
break;
public SqlDataReader SqlGetReader(string strQuery)
//返回一个SqlDataReader。用於Sql server
SQL_SELECT = strQuery;
sqlCmd = new SqlCommand(strQuery,sqlConn);
SqlDataReader dr;
try
sqlCmd.Connection.Open();
catch (Exception e)
throw e;
dr = sqlCmd.ExecuteReader();
return dr;
public OleDbDataReader OleGetReader(string strQuery)
//返回一个OleDbDataReader。用於OleDb
SQL_SELECT = strQuery;
oleCmd = new OleDbCommand(strQuery,oleConn);
OleDbDataReader dr;
try
oleCmd.Connection.Open();
catch (Exception e)
throw e;
dr = oleCmd.ExecuteReader();
return dr;
public int SqlRunCommand(string strQuery)
//执行一条SQL语句。包括记录插入、更新、删除。用於Sql server
SQL_SELECT = strQuery;
sqlCmd = new SqlCommand(strQuery,sqlConn);
try
sqlCmd.Connection.Open();
catch (Exception e)
throw e;
return sqlCmd.ExecuteNonQuery();
public int OleRunCommand(string strQuery)
//执行一条SQL语句。包括记录插入、更新、删除。用於OleDb
SQL_SELECT = strQuery;
oleCmd = new OleDbCommand(strQuery,oleConn);
try
oleCmd.Connection.Open();
catch (Exception e)
throw e;
return oleCmd.ExecuteNonQuery();
public DataView SqlGetDataSet(string strQuery)
//返回一个DataSet。用於Sql server
SQL_SELECT = strQuery;
sqlCmd = new SqlCommand(strQuery,sqlConn);
try
sqlCmd.Connection.Open();
catch (Exception e)
throw e;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = sqlCmd;
da.Fill(ds,"DefaultTable");
return ds.Tables["DefaultTable"].DefaultView;
public DataView OleGetDataSet(string strQuery)
//返回一个DataSet。用於OleDb
SQL_SELECT = strQuery;
oleCmd = new OleDbCommand(strQuery,oleConn);
try
oleCmd.Connection.Open();
catch (Exception e)
throw e;
OleDbDataAdapter da = new OleDbDataAdapter();
da.SelectCommand = oleCmd;
da.Fill(ds,"DefaultTable");
return ds.Tables["DefaultTable"].DefaultView;
public void Close()
//数据库关闭。
switch (DBTYPE)
case "SQL":
sqlCmd.Cancel();
sqlCmd.Dispose();
sqlConn.Close();
sqlConn.Dispose();
break;
case "OLE":
oleCmd.Cancel();
oleCmd.Dispose();
oleConn.Close();
oleConn.Dispose();
break;
ds.Clear();
ds.Dispose();
============================================================
\Classes\DataBaseType\DbOpen.cs
============================================================
using System;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Configuration;
namespace GuestBook.Classes.DataBaseType
/// <summary>
/// DbOpen 的摘要描述。
/// </summary>
public class DbOpen
public DbOpen()
//
// TODO: 在这里加入建构函式的程式码
//
protected SqlConnection SqlConnect(string dbName)
SqlConnection conn = new SqlConnection(ConfigurationSettings.AppSettings[dbName]);
return conn;
protected OleDbConnection OleConnect(string dbName)
OleDbConnection conn = new OleDbConnection(ConfigurationSettings.AppSettings[dbName]);
return conn;
==============================================================
类的调用方法：
==============================================================
DbControl objDbControl = new DbControl();
string SQL = "SELECT * FROM content";
objDbControl.Open("sql","sqlConnection");
dgList.DataSource = objDbControl.SqlGetDataSet(SQL);
intTotal = objDbControl.RecordTotal;
dgList.DataBind();
objDbControl.Close();
==============================================================
其中“intTotal = objDbControl.RecordTotal;”即返回记录总数。
可以把它插入到DataGrid中。如：
==============================================================
private void dgList_ItemCreated(object sender, System.Web.UI.WebControls.DataGridItemEventArgs e)
if (e.Item.ItemType == ListItemType.Pager)
System.Text.StringBuilder pagerString = new System.Text.StringBuilder();
pagerString.Append("总计" + intTotal.ToString() + " 共" + dgList.PageCount + "页 每页" + dgList.PageSize + "笔");
e.Item.Cells[0].Controls.AddAt(0,new LiteralControl(pagerString.ToString())) ;
参考技术D 这是我自己写的一个sql操作类，希望你能用上：
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
namespace HotelDAL
public abstract class MyDB
//连接对象
private SqlConnection con = null;
protected SqlConnection Con
get return con;
set con = value;
protected MyDB()
if (con==null)
string s=ConfigurationManager.ConnectionStrings["sqlCon"].ConnectionString;
con = new SqlConnection(s);
protected SqlCommand CreateCommand(string text,CommandType type,SqlParameter [] param)
SqlCommand cmd = new SqlCommand(text,Con);
cmd.CommandType = type;
if (param != null)
cmd.Parameters.AddRange(param);
return cmd;
protected SqlParameter CreateParam(string paramName,SqlDbType type,int size,object value)
SqlParameter param = new SqlParameter();
param.ParameterName = paramName;
param.SqlDbType = type;
param.Size = size;
param.Value = value;
return param;
protected int ExecuteNonQuery(SqlCommand cmd)
cmd.Connection.Open();
int i = cmd.ExecuteNonQuery();
cmd.Connection.Close();
return i;
protected SqlDataReader ExecuteReader(SqlCommand cmd)
cmd.Connection.Open();
SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
return dr;
protected object ExecuteScalar(SqlCommand cmd)
cmd.Connection.Open();
object i = cmd.ExecuteScalar();
cmd.Connection.Close();
return i;
protected DataTable GetTable(SqlCommand cmd,string tableName)
SqlDataAdapter da = new SqlDataAdapter(cmd);
DataTable dt = new DataTable(tableName);
da.Fill(dt);
return dt;
如何在 C# 中调用 Web 服务
【中文标题】如何在 C# 中调用 Web 服务【英文标题】：How to call web Services in C# 【发布时间】：2021-01-06 00:29:36 【问题描述】：我正在调用 Web 服务并返回列表，但我不能这样做。 我想将下拉列表与 Web 服务绑定。
我添加了 INITIATORS_LIST 类，其中包含我想在下拉列表中绑定的所有字段，例如公司、国家、部门、位置......等等。请问我该如何实现我可以接受的任何替代方法？
示例 JSON 数据
"Companies":["ACTIVE":true,"COMPANY_ID":1,"CompanyCode":"1000","CompanyName":"Almarai Company","CountryCode":"SAU","CountryName":"Saudi Arabia","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","ACTIVE":true,"COMPANY_ID":6,"CompanyCode":"4000","CompanyName":"Almarai Co. Bahrain WLL","CountryCode":"BAH","CountryName":"Bahrain","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","ACTIVE":true,"COMPANY_ID":8,"CompanyCode":"5000","CompanyName":"Bustan Al Khaleej Est.","CountryCode":"UAE","CountryName":"United Arab Emirates","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","ACTIVE":true,"COMPANY_ID":11,"CompanyCode":"5200","CompanyName":"ALMARAI EMIRATES COMPANY L.L.C","CountryCode":"UAE","CountryName":"United Arab Emirates","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","ACTIVE":true,"COMPANY_ID":15,"CompanyCode":"6000","CompanyName":"Al Kharafi Brothers","CountryCode":"KWT","CountryName":"Kuwait","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","ACTIVE":true,"COMPANY_ID":18,"CompanyCode":"7000","CompanyName":"Ar*** Planets Company","CountryCode":"OMN","CountryName":"Oman","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales"],"Countries":["COUNTRY_ACTIVE":true,"COUNTRY_M_ID":1,"CountryCode":"SAU","CountryName":"Saudi Arabia","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","COUNTRY_ACTIVE":true,"COUNTRY_M_ID":3,"CountryCode":"UAE","CountryName":"United Arab Emirates","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","COUNTRY_ACTIVE":true,"COUNTRY_M_ID":4,"CountryCode":"BAH","CountryName":"Bahrain","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","COUNTRY_ACTIVE":true,"COUNTRY_M_ID":5,"CountryCode":"OMN","CountryName":"Oman","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","COUNTRY_ACTIVE":true,"COUNTRY_M_ID":7,"CountryCode":"KWT","CountryName":"Kuwait","DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales"],"Divisions":["ACTIVE":true,"CompanyCode":null,"CompanyName":null,"CountryCode":null,"CountryName":null,"DB_CONNECTION_STRING":null,"DivisionCode":"1000","DivisionId":1,"DivisionName":"Sales","WEB_URL":null],"Locations":
ALM_COUNTRY_M 类：
public partial class ALM_COUNTRY_M : object, System.Runtime.Serialization.IExtensibleDataObject,
System.ComponentModel.INotifyPropertyChanged
[System.NonSerializedAttribute()]
private System.Runtime.Serialization.ExtensionDataObject extensionDataField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private bool COUNTRY_ACTIVEField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private int COUNTRY_M_IDField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private string CountryCodeField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private string CountryNameField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private string DivisionCodeField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private int DivisionIdField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private string DivisionNameField;
[global::System.ComponentModel.BrowsableAttribute(false)]
public System.Runtime.Serialization.ExtensionDataObject ExtensionData
get
return this.extensionDataField;
set
this.extensionDataField = value;
[System.Runtime.Serialization.DataMemberAttribute()]
public bool COUNTRY_ACTIVE
get
return this.COUNTRY_ACTIVEField;
set
if ((this.COUNTRY_ACTIVEField.Equals(value) != true))
this.COUNTRY_ACTIVEField = value;
this.RaisePropertyChanged("COUNTRY_ACTIVE");
[System.Runtime.Serialization.DataMemberAttribute()]
public int COUNTRY_M_ID
get
return this.COUNTRY_M_IDField;
set
if ((this.COUNTRY_M_IDField.Equals(value) != true))
this.COUNTRY_M_IDField = value;
this.RaisePropertyChanged("COUNTRY_M_ID");
[System.Runtime.Serialization.DataMemberAttribute()]
public string CountryCode
get
return this.CountryCodeField;
set
if ((object.ReferenceEquals(this.CountryCodeField, value) != true))
this.CountryCodeField = value;
this.RaisePropertyChanged("CountryCode");
[System.Runtime.Serialization.DataMemberAttribute()]
public string CountryName
get
return this.CountryNameField;
set
if ((object.ReferenceEquals(this.CountryNameField, value) != true))
this.CountryNameField = value;
this.RaisePropertyChanged("CountryName");
[System.Runtime.Serialization.DataMemberAttribute()]
public string DivisionCode
get
return this.DivisionCodeField;
set
if ((object.ReferenceEquals(this.DivisionCodeField, value) != true))
this.DivisionCodeField = value;
this.RaisePropertyChanged("DivisionCode");
[System.Runtime.Serialization.DataMemberAttribute()]
public int DivisionId
get
return this.DivisionIdField;
set
if ((this.DivisionIdField.Equals(value) != true))
this.DivisionIdField = value;
this.RaisePropertyChanged("DivisionId");
[System.Runtime.Serialization.DataMemberAttribute()]
public string DivisionName
get
return this.DivisionNameField;
set
if ((object.ReferenceEquals(this.DivisionNameField, value) != true))
this.DivisionNameField = value;
this.RaisePropertyChanged("DivisionName");
public event System.ComponentModel.PropertyChangedEventHandler PropertyChanged;
protected void RaisePropertyChanged(string propertyName)
System.ComponentModel.PropertyChangedEventHandler propertyChanged = this.PropertyChanged;
if ((propertyChanged != null))
propertyChanged(this, new System.ComponentModel.PropertyChangedEventArgs(propertyName));
INITIATORS_LIST 类：
public partial class INITIATORS_LIST : object, System.Runtime.Serialization.IExtensibleDataObject, System.ComponentModel.INotifyPropertyChanged
[System.NonSerializedAttribute()]
private System.Runtime.Serialization.ExtensionDataObject extensionDataField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private Almarai.GiveAway.GetInitiatorList.ALM_COMPANY_M[] CompaniesField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private Almarai.GiveAway.GetInitiatorList.ALM_COUNTRY_M[] CountriesField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private Almarai.GiveAway.GetInitiatorList.ALM_DIVISION_M[] DivisionsField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private Almarai.GiveAway.GetInitiatorList.LOCATION[] LocationsField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private Almarai.GiveAway.GetInitiatorList.REGION[] RegionsField;
[System.Runtime.Serialization.OptionalFieldAttribute()]
private Almarai.GiveAway.GetInitiatorList.ALM_WKFLW_TYPE_M[] WorkflowTypesField;
[global::System.ComponentModel.BrowsableAttribute(false)]
public System.Runtime.Serialization.ExtensionDataObject ExtensionData
get
return this.extensionDataField;
set
this.extensionDataField = value;
[System.Runtime.Serialization.DataMemberAttribute()]
public Almarai.GiveAway.GetInitiatorList.ALM_COMPANY_M[] Companies
get
return this.CompaniesField;
set
if ((object.ReferenceEquals(this.CompaniesField, value) != true))
this.CompaniesField = value;
this.RaisePropertyChanged("Companies");
[System.Runtime.Serialization.DataMemberAttribute()]
public Almarai.GiveAway.GetInitiatorList.ALM_COUNTRY_M[] Countries
get
return this.CountriesField;
set
if ((object.ReferenceEquals(this.CountriesField, value) != true))
this.CountriesField = value;
this.RaisePropertyChanged("Countries");
[System.Runtime.Serialization.DataMemberAttribute()]
public Almarai.GiveAway.GetInitiatorList.ALM_DIVISION_M[] Divisions
get
return this.DivisionsField;
set
if ((object.ReferenceEquals(this.DivisionsField, value) != true))
this.DivisionsField = value;
this.RaisePropertyChanged("Divisions");
[System.Runtime.Serialization.DataMemberAttribute()]
public Almarai.GiveAway.GetInitiatorList.LOCATION[] Locations
get
return this.LocationsField;
set
if ((object.ReferenceEquals(this.LocationsField, value) != true))
this.LocationsField = value;
this.RaisePropertyChanged("Locations");
[System.Runtime.Serialization.DataMemberAttribute()]
public Almarai.GiveAway.GetInitiatorList.REGION[] Regions
get
return this.RegionsField;
set
if ((object.ReferenceEquals(this.RegionsField, value) != true))
this.RegionsField = value;
this.RaisePropertyChanged("Regions");
[System.Runtime.Serialization.DataMemberAttribute()]
public Almarai.GiveAway.GetInitiatorList.ALM_WKFLW_TYPE_M[] WorkflowTypes
get
return this.WorkflowTypesField;
set
if ((object.ReferenceEquals(this.WorkflowTypesField, value) != true))
this.WorkflowTypesField = value;
this.RaisePropertyChanged("WorkflowTypes");
public event System.ComponentModel.PropertyChangedEventHandler PropertyChanged;
protected void RaisePropertyChanged(string propertyName)
System.ComponentModel.PropertyChangedEventHandler propertyChanged = this.PropertyChanged;
if ((propertyChanged != null))
propertyChanged(this, new System.ComponentModel.PropertyChangedEventArgs(propertyName));
参考：
public Almarai.GiveAway.GetInitiatorList.INITIATORS_LIST GetInitiatorsListByWorkflow(string userId, string WorkflowTypeCode)
return base.Channel.GetInitiatorsListByWorkflow(userId, WorkflowTypeCode);
[System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IMasterDataService/GetInitiatorsListByWorkflow", ReplyAction="http://tempuri.org/IMasterDataService/GetInitiatorsListByWorkflowResponse")]
[System.ServiceModel.FaultContractAttribute(typeof(Almarai.GiveAway.GetInitiatorList.CustomFaultException), Action="http://tempuri.org/IMasterDataService/GetInitiatorsListByWorkflowCustomFaultExcep" +
"tionFault", Name="CustomFaultException", Namespace="http://schemas.datacontract.org/2004/07/Almarai.Web.Services.MasterData")]
Almarai.GiveAway.GetInitiatorList.INITIATORS_LIST GetInitiatorsListByWorkflow(string userId, string WorkflowTypeCode);
国家类：（我是否应该为公司、国家、地区等每个不同的字段更改此类）
public class CountryList
public CountryList(INITIATORS_LIST data)
ExtensionData = data;
public INITIATORS_LIST ExtensionData get; internal set;
我的方法：（我应该如何修改我的方法）
[WebMethod]
public static List<CountryList> GetCountriesName(string UserID)
GetInitiatorList.MasterDataServiceClient oClient = new GetInitiatorList.MasterDataServiceClient();
string userid = "approver01";
string work = "4";
List<CountryList> countries = oClient.GetInitiatorsListByWorkflow(userid, work); // Error on this line
foreach (Country c in countries)
lst.Add(c.Name);
return lst; //Error on this line
我无法添加到列表中还有其他方法吗？ 我知道由于返回类型我无法做到，但是
【问题讨论】：
评论不用于扩展讨论；这个对话是moved to chat。 【参考方案1】：GetInitiatorsListByWorkflow 方法返回 Almarai.GiveAway.GetInitiatorList.INITIATORS_LIST 对象，而不是 List<CountryList>。同样，您的 GetCountriesName 方法返回 List<CountryList>，而不是您的（在显示的代码中未定义）lst 变量的类型。这就是你有错误的原因 - 你不能只是随机地将对象分配给错误类型的变量。
无论如何，对于您的国家/地区列表，您实际上希望使用 ALM_COUNTRY_M 类中的两个属性。 INITIATORS_LIST 包含该类型的对象数组。
所以你真正需要做的是从GetInitiatorsListByWorkflow 方法返回的INITIATORS_LIST 中获取ALM_COUNTRY_M 对象的数组，然后循环遍历它们，并为每个对象创建一个CountryList 的等效实例，使用 ALM_COUNTRY_M 对象中的值设置其属性，并将其添加到要返回的列表中。
类似这样的东西（未经测试）：
[WebMethod]
public static List<CountryList> GetCountriesName(string UserID)
GetInitiatorList.MasterDataServiceClient oClient = new GetInitiatorList.MasterDataServiceClient();
string userid = "approver01";
string work = "4";
Almarai.GiveAway.GetInitiatorList.INITIATORS_LIST initiatorsList = oClient.GetInitiatorsListByWorkflow(userid, work); //get data from webservice
Almarai.GiveAway.GetInitiatorList.ALM_COUNTRY_M[] countryMList = initiatorsList.Countries; //get list of countries from the data returned by the webservice
List<CountryList> countries = new List<CountryList>(); //create an empty list which will be populated with data from the webservice
//loop through list of countries returned from webservice
foreach (Almarai.GiveAway.GetInitiatorList.ALM_COUNTRY_M country in countryMList)
//add new instance of CountryList using fields from the webservice class
countries.Add(new CountryList()
CountryCode = country.CountryCode,
CountryName = country.CountryName
);
return countries; //return the completed list of countries
CountryList 类的定义应该更像这样：
public class CountryList
public string CountryCode get; set;
public string CountryName get; set;
附：将CountryList 类重命名为Country 会更有意义，因为每个对象只代表一个国家。它是定义列表的List<> 部分。但这是一个由您决定的单独问题。
【讨论】：
以上是关于C#中如何定义数据库操作类，并调用？的主要内容，如果未能解决你的问题，请参考以下文章