wcf数据库操作实例

using System;
using System.ServiceModel;
using System.Data.SqlClient;

namespace WCFDatabaseExample
{
    [ServiceContract]
    public interface IDatabaseService
    {
        [OperationContract]
        string GetData(int id);
    }

    public class DatabaseService : IDatabaseService
    {
        private const string connectionString = "Data Source=.;Initial Catalog=TestDB;Integrated Security=True";

        public string GetData(int id)
        {
            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                connection.Open();
                SqlCommand command = new SqlCommand("SELECT * FROM Customers WHERE CustomerID = @CustomerID", connection);
                command.Parameters.AddWithValue("@CustomerID", id);
                SqlDataReader reader = command.ExecuteReader();
                if (reader.Read())
                {
                    return reader["CompanyName"].ToString();
                }
            }
            return null;
        }
    }

    class Program
    {
        static void Main(string[] args)
        {
            ServiceHost host = new ServiceHost(typeof(DatabaseService));
            host.AddServiceEndpoint(typeof(IDatabaseService), new BasicHttpBinding(), "http://localhost:8000/DatabaseService");
            host.Open();
            Console.WriteLine("Service is ready.");
            Console.ReadLine();
            host.Close();
        }
    }
}