Spring.NET 与 NHibernate

您可以从以下网址下载最新版：http://tech.bokeecn.com

本文中的源代码下载地址：http://tech.bokeecn.com

作    者：李绿华 (William Lee)

制作时间：2006-11-30

版 本 号：V 0.50

using System;

namespace quicksort

{

///

/// Summary description for Class1.

///

class Class1

{

static void Main(string[] args)

{

//

// TODO: Add code to start application here

//

Console.WriteLine ("Hello, C#.NET World!");

}

}

}

// This line is ignored by the compiler.

/* This block of text is also

ignored by the Visual C# compiler. */

using System;

class Class1

{

static void Main(string[] args)

{

System.Console.WriteLine ("Hello, C#.NET World!");

Console.WriteLine ("Hello, C#.NET World!");

}

}

// Import namespaces

using System;

// Declare namespace

namespace MsdnAA

{

// Declare application class

class QuickSortApp

{

// Application initialization

static void Main (string[] szArgs)

{

// Describe program function

Console.WriteLine ("QuickSort C#.NET Sample Application\n");

// Prompt user for filenames

Console.Write ("Source: ");

string szSrcFile = Console.ReadLine ();

Console.Write ("Output: ");

string szDestFile = Console.ReadLine ();

}

}

}

// Import namespaces

using System;

using System.Collections;

// Declare namespace

namespace MsdnAA

{

// Declare application class

class QuickSortApp

{

// Application initialization

static void Main (string[] szArgs)

{

// Describe program function

Console.WriteLine ("QuickSort C#.NET Sample Application\n");

// Prompt user for filenames

Console.Write ("Source: ");

string szSrcFile = Console.ReadLine ();

Console.Write ("Output: ");

string szDestFile = Console.ReadLine ();

// TODO: Read contents of source file

ArrayList szContents = new ArrayList ();

}

}

}

string szElement = "insert-me";

ArrayList szArray = new ArrayList ();

szArray.Add (szElement);

Console.WriteLine (szArray[2]);

Console.WriteLine (szArray.Item (2));

// Import namespaces

using System;

using System.Collections;

using System.IO;

// Declare namespace

namespace MsdnAA

{

// Declare application class

class QuickSortApp

{

// Application initialization

static void Main (string[] szArgs)

{

... ... ...

// Read contents of source file

string szSrcLine;

ArrayList szContents = new ArrayList ();

FileStream fsInput = new FileStream (szSrcFile, FileMode.Open,

FileAccess.Read);

StreamReader srInput = new StreamReader (fsInput);

while ((szSrcLine = srInput.ReadLine ()) != null)

{

// Append to array

szContents.Add (szSrcLine);

}

srInput.Close ();

fsInput.Close ();

// TODO: Pass to QuickSort function

// Write sorted lines

FileStream fsOutput = new FileStream (szDestFile,

FileMode.Create, FileAccess.Write);

StreamWriter srOutput = new StreamWriter (fsOutput);

for (int nIndex = 0; nIndex < szContents.Count; nIndex++)

{

// Write line to output file

srOutput.WriteLine (szContents[nIndex]);

}

srOutput.Close ();

fsOutput.Close ();

// Report program success

Console.WriteLine ("\nThe sorted lines have been written.\n\n");

}

}

}

// Import namespaces

using System;

using System.Collections;

using System.IO;

// Declare namespace

namespace MsdnAA

{

// Declare application class

class QuickSortApp

{

// Application initialization

static void Main (string[] szArgs)

{

... ... ...

// Pass to QuickSort function

QuickSort (szContents, 0, szContents.Count - 1);

... ... ...

}

// QuickSort implementation

static void QuickSort (ArrayList szArray, int nLower, int nUpper)

{

// Check for non-base case

if (nLower < nUpper)

{

// Split and sort partitions

int nSplit = Partition (szArray, nLower, nUpper);

QuickSort (szArray, nLower, nSplit - 1);

QuickSort (szArray, nSplit + 1, nUpper);

}

}

// QuickSort partition implementation

static int Partition (ArrayList szArray, int nLower, int nUpper)

{

// Pivot with first element

int nLeft = nLower + 1;

string szPivot = (string) szArray[nLower];

int nRight = nUpper;

// Partition array elements

string szSwap;

while (nLeft <= nRight)

{

// Find item out of place

while (nLeft <= nRight)

{

if (((string) szArray[nLeft]).CompareTo (szPivot) > 0)

break;

nLeft = nLeft + 1;

}

while (nLeft <= nRight)

{

if (((string) szArray[nRight]).CompareTo (szPivot) <= 0)

break;

nRight = nRight - 1;

}

// Swap values if necessary

if (nLeft < nRight)

{

szSwap = (string) szArray[nLeft];

szArray[nLeft] = szArray[nRight];

szArray[nRight] = szSwap;

nLeft = nLeft + 1;

nRight = nRight - 1;

}

}

// Move pivot element

szSwap = (string) szArray[nLower];

szArray[nLower] = szArray[nRight];

szArray[nRight] = szSwap;

return nRight;

}

}

}

using System;

namespace OKEC.Sample.Spring

{

/// <summary>

/// HelloTest 的摘要说明。

/// </summary>

public class HelloTest

{

public HelloTest()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

public void Test()

{

Console.WriteLine("This is Spring.NET Sample Test!");

Console.WriteLine("Please press Enter close the windows!");

Console.ReadLine();//让程序停留，回车关闭。

}

}

}

<?xml version="1.0" encoding="utf-8"?>

<objects xmlns="http://www.springframework.net" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://www.springframework.net

http://www.springframework.net/xsd/spring-objects.xsd">

<object id="Hello" type="OKEC.Sample.Spring.HelloTest,SpringSample" />

</objects>

using System;

using Spring.Core;

using Spring.Aop;

using System;

using Spring.Core;

using Spring.Aop;

using Spring.Context;

using Spring.Context.Support;

namespace OKEC.Sample.Spring

{

/// <summary>

/// SpringFactory 的摘要说明。

/// </summary>

public class SpringContext

{

public SpringContext()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

private static bool isInit = false;

private static IApplicationContext context;

public static void init()

{

string[] xmlFiles = new string[1];

xmlFiles[0] = "assembly://SpringSample/OKEC.Sample.Spring/Spring_bean.xml";

context = new XmlApplicationContext(xmlFiles);

isInit = true;

}

public static IApplicationContext Context

{

get{

if(!isInit)

{

init();

}

return context;

}

}

}

}

using System;

namespace OKEC.Sample.Spring

{

/// <summary>

/// StartMain 的摘要说明。

/// </summary>

public class StartMain

{

public StartMain()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

[STAThread]

static void Main()

{

//Startup Spring Content

SpringContext.init();

//Test Spring IOC

HelloTest test = (HelloTest)SpringContext.Context.GetObject("Hello");

test.Test();

}

}

}

This is Spring.NET Sample Test!

Please press Enter close the windows!

if exists (select * from dbo.sysobjects where id = object_id(N'[dbo].[my_users]') and OBJECTPROPERTY(id, N'IsUserTable') = 1)

drop table [dbo].[my_users]

GO

CREATE TABLE [dbo].[my_users] (

[LogonId] [varchar] (50) COLLATE Chinese_PRC_CI_AS NOT NULL ,

[UserName] [varchar] (50) COLLATE Chinese_PRC_CI_AS NULL ,

[Password] [varchar] (50) COLLATE Chinese_PRC_CI_AS NULL ,

[EmailAddress] [varchar] (50) COLLATE Chinese_PRC_CI_AS NULL ,

[LastLogon] [datetime] NULL

) ON [PRIMARY]

GO

ALTER TABLE [dbo].[my_users] ADD

CONSTRAINT [PK_my_users] PRIMARY KEY  CLUSTERED

(

[LogonId]

)  ON [PRIMARY]

GO

<?xml version="1.0" encoding="utf-8" ?>

<hibernate-mapping xmlns="urn:nhibernate-mapping-2.0">

<class name=" OKEC.Sample.NHibernate.NHibernateTest.User,NHibernateSample" table="my_users">

<id name="Id" column="LogonId" type="String" length="20">

<generator class="assigned" />

</id>

<property name="UserName" column="UserName" type="String" length="40"/>

<property name="Password" column="Password" type="String" length="20"/>

<property name="EmailAddress" column="EmailAddress" type="String" length="40"/>

<property name="LastLogon" column="LastLogon" type="DateTime"/>

</class>

</hibernate-mapping>

using System;

namespace OKEC.Sample.NHibernate.NHibernateTest

{

/// <summary>

/// Summary description for User.

/// </summary>

public class User

{

private string id;

private string userName;

private string password;

private string emailAddress;

private DateTime lastLogon;

public User()

{

}

public string Id

{

get { return id; }

set { id = value; }

}

public string UserName

{

get { return userName; }

set { userName = value; }

}

public string Password

{

get { return password; }

set { password = value; }

}

public string EmailAddress

{

get { return emailAddress; }

set { emailAddress = value; }

}

public DateTime LastLogon

{

get { return lastLogon; }

set { lastLogon = value; }

}

}

}

using System;

using NHibernate.Cfg;

namespace OKEC.Sample.NHibernate.NHibernateTest

{

/// <summary>

/// MyConfiguration 的摘要说明。

/// </summary>

public class MyConfiguration

{

public MyConfiguration()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

public Configuration GetConfig()

{

try

{

Configuration cfg = new Configuration();              cfg.SetProperty("hibernate.connection.provider","NHibernate.Connection.DriverConnectionProvider");

//请修改此行中的SQLServer的配置

cfg.SetProperty("hibernate.connection.connection_string","Data Source=192.168.88.15;Database=liluhua;User ID=sa;Password=sa;Trusted_Connection=False");

cfg.SetProperty("hibernate.dialect","NHibernate.Dialect.MsSql2000Dialect");

cfg.SetProperty("hibernate.connection.driver_class","NHibernate.Driver.SqlClientDriver");

cfg.AddAssembly("NHibernateSample");

return cfg;

}

catch(Exception ex)

{

Console.WriteLine(ex.Message);

Console.WriteLine(ex.StackTrace);

}

return null;

}

}

}

using System;

using System.Collections;

using NHibernate;

using NHibernate.Cfg;

using NHibernate.Expression;

namespace OKEC.Sample.NHibernate.NHibernateTest

{

/// <summary>

/// UserFixture 的摘要说明。

/// </summary>

public class UserFixture

{

public UserFixture()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

public void ValidateQuickStart()

{

try

{

//得到NHibernate的配置

MyConfiguration config = new MyConfiguration();

Configuration cfg = config.GetConfig();

ISessionFactory factory = cfg.BuildSessionFactory();

ISession session = factory.OpenSession();

ITransaction transaction = session.BeginTransaction();

User newUser = null;

try

{

newUser = (User)session.Load(typeof(User), "joe_cool");

}

catch

{

}

if(newUser==null)

{

newUser = new User();

newUser.Id = "joe_cool";

newUser.UserName = "Joseph Cool";

newUser.Password = "abc123";

newUser.EmailAddress = "joe@cool.com";

newUser.LastLogon = DateTime.Now;

// Tell NHibernate that this object should be saved

session.Save(newUser);

}

// commit all of the changes to the DB and close the ISession

transaction.Commit();

session.Close();

// open another session to retrieve the just inserted user

session = factory.OpenSession();

User joeCool = (User)session.Load(typeof(User), "joe_cool");

// set Joe Cool's Last Login property

joeCool.LastLogon = DateTime.Now;

// flush the changes from the Session to the Database

session.Flush();

IList recentUsers = session.CreateCriteria(typeof(User))

.Add(Expression.Gt("LastLogon", new DateTime(2004, 03, 14, 20, 0, 0)))

.List();

foreach(User user in recentUsers)

{

//Assert.IsTrue(user.LastLogon > (new DateTime(2004, 03, 14, 20, 0, 0)) );

Console.WriteLine(user.UserName);

Console.WriteLine(user.Password);

}

session.Close();

}

catch(Exception ex)

{

Console.WriteLine(ex.Message);

Console.WriteLine(ex.StackTrace);

}

Console.ReadLine();

}

}

}

Joseph Cool

abc123

<class name=" OKEC.Sample.NHibernate.NHibernateTest.User,NHibernateSample"

table="my_users">

<class name=" OKEC.Sample.NHibernate.NHibernateTest.User,SpringNHibernateSample"

table="my_users">

<object id="Hello" type="OKEC.Sample.Spring.HelloTest,SpringSample" />

<object id="Hello" type="OKEC.Sample.Spring.HelloTest,SpringNHibernateSample" />

using System;

using Spring.Data.Common;

namespace OKEC.Sample.Spring

{

/// <summary>

/// SQLPriv 的摘要说明。

/// </summary>

public class SQLProvider:IDbProvider

{

public SQLProvider()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

#region IDbProvider 成员

public System.Data.IDbConnection CreateConnection()

{

// TODO:  添加 SQLPriv.CreateConnection 实现

return null;

}

public string CreateParameterName(string name)

{

// TODO:  添加 SQLPriv.CreateParameterName 实现

return null;

}

public System.Data.IDbDataParameter CreateParameter()

{

// TODO:  添加 SQLPriv.CreateParameter 实现

return null;

}

private string _connectionString="";

public string ConnectionString

{

get

{

// TODO:  添加 SQLPriv.ConnectionString getter 实现

return _connectionString;

}

set

{

_connectionString = value;

// TODO:  添加 SQLPriv.ConnectionString setter 实现

}

}

public string ExtractError(Exception e)

{

// TODO:  添加 SQLPriv.ExtractError 实现

return null;

}

public System.Data.IDbDataAdapter CreateDataAdapter()

{

// TODO:  添加 SQLPriv.CreateDataAdapter 实现

return null;

}

public bool IsDataAccessException(Exception e)

{

// TODO:  添加 SQLPriv.IsDataAccessException 实现

return false;

}

public System.Data.IDbCommand CreateCommand()

{

// TODO:  添加 SQLPriv.CreateCommand 实现

return null;

}

public object CreateCommandBuilder()

{

// TODO:  添加 SQLPriv.CreateCommandBuilder 实现

return null;

}

public IDbMetadata DbMetadata

{

get

{

// TODO:  添加 SQLPriv.DbMetadata getter 实现

return null;

}

}

#endregion

}

}

using System;

using System.Collections;

using Spring.Data.NHibernate.Support;

namespace OKEC.Sample.NHibernate.NHibernateTest

{

/// <summary>

/// UserDao 的摘要说明。

/// </summary>

public class UserDao : HibernateDaoSupport

{

public UserDao()

{    //

// TODO: 在此处添加构造函数逻辑

//

}

public bool SaveObject(User user)

{

HibernateTemplate.Save(user);

return true;

}

public bool DeleteObject(User user)

{

HibernateTemplate.Delete(user);

return true;

}

public bool UpdateObject(User user)

{

HibernateTemplate.Update(user);

return true;

}

public IList GetAllObjectsList()

{

return HibernateTemplate.LoadAll(typeof(User));

}

public User Load(Object ID)

{

return (User)HibernateTemplate.Load(typeof(User),ID);

}

}

}

<?xml version="1.0" encoding="utf-8" ?>

<objects xmlns='http://www.springframework.net'>

<!-- NHibernate初始化的 -->

<object id="DbProvider" type="OKEC.Sample.Spring.SQLProvider,SpringNHibernateSample">

<property name="ConnectionString" value="Data Source=192.168.88.15;Database=liluhua;User ID=sa;Password=sa;Trusted_Connection=False"/>

</object>

<object id="SessionFactory"

type="Spring.Data.NHibernate.LocalSessionFactoryObject, Spring.Data.NHibernate">

<property name="DbProvider" ref="DbProvider"/>

<property name="MappingAssemblies">

<list>

<value>SpringNhibernateSample</value>

</list>

</property>

<property name="HibernateProperties">

<dictionary>

<entry

key="hibernate.connection.provider" value="NHibernate.Connection.DriverConnectionProvider"/>

<!--entry

key="hibernate.connection.connection_string" value="Data Source=192.168.188.188;Database=Test;User ID=satest;Password=satest;Trusted_Connection=False"/-->

<entry key="hibernate.dialect" value="NHibernate.Dialect.MsSql2000Dialect"/>

<entry

key="hibernate.connection.driver_class" value="NHibernate.Driver.SqlClientDriver"/>

</dictionary>

</property>

</object>

<object id="HibernateTransactionManager" type="Spring.Data.NHibernate.HibernateTransactionManager, Spring.Data.NHibernate">

<property name="DbProvider" ref="DbProvider"/>

<property name="sessionFactory" ref="SessionFactory"/>

</object>

<object id="TransactionInterceptor"

type="Spring.Transaction.Interceptor.TransactionInterceptor, Spring.Data">

<property name="TransactionManager" ref="HibernateTransactionManager"/>

<property name="TransactionAttributeSource">

<object

type="Spring.Transaction.Interceptor.AttributesTransactionAttributeSource, Spring.Data"/>

</property>

</object>

<!-- 以下是业务相关的 -->

<object id="UserDao"

type="OKEC.Sample.NHibernate.NHibernateTest.UserDao, SpringNHibernateSample">

<property name="SessionFactory" ref="SessionFactory"/>

</object>

</objects>

<object id="DbProvider" type="OKEC.Sample.Spring.SQLProvider,SpringNHibernateSample">

<property name="ConnectionString" value="Data Source=192.168.88.15;Database=liluhua;User ID=sa;Password=sa;Trusted_Connection=False"/>

</object>

<object id="SessionFactory"

type="Spring.Data.NHibernate.LocalSessionFactoryObject, Spring.Data.NHibernate">

<property name="DbProvider" ref="DbProvider"/>

<property name="MappingAssemblies">

<list>

<value>SpringNhibernateSample</value>

</list>

</property>

<property name="HibernateProperties">

<dictionary>

<entry key="hibernate.connection.provider" value="NHibernate.Connection.DriverConnectionProvider"/>

<!--entry key="hibernate.connection.connection_string" value="Data Source=192.168.188.188;Database=Test;User ID=satest;Password=satest;Trusted_Connection=False"/-->

<entry key="hibernate.dialect" value="NHibernate.Dialect.MsSql2000Dialect"/>

<entry key="hibernate.connection.driver_class" value="NHibernate.Driver.SqlClientDriver"/>

</dictionary>

</property>

</object>

<object id="HibernateTransactionManager" type="Spring.Data.NHibernate.HibernateTransactionManager, Spring.Data.NHibernate">

<property name="DbProvider" ref="DbProvider"/>

<property name="sessionFactory" ref="SessionFactory"/>

</object>

<object id="TransactionInterceptor" type="Spring.Transaction.Interceptor.TransactionInterceptor, Spring.Data">

<property name="TransactionManager" ref="HibernateTransactionManager"/>

<property name="TransactionAttributeSource">

<object type="Spring.Transaction.Interceptor.AttributesTransactionAttributeSource, Spring.Data"/>

</property>

</object>

<object id="UserDao"

type="OKEC.Sample.NHibernate.NHibernateTest.UserDao, SpringNHibernateSample">

<property name="SessionFactory" ref="SessionFactory"/>

</object>

using System;

using System.Collections;

using OKEC.Sample.NHibernate.NHibernateTest;

namespace OKEC.Sample.Spring

{

/// <summary>

/// StartMain 的摘要说明。

/// </summary>

public class StartMain

{

public StartMain()

{  //

// TODO: 在此处添加构造函数逻辑

//

}

[STAThread]

static void Main()

{

//Startup Spring & NHibernate Content

SpringContext.init();

//Test Spring IOC

HelloTest test = (HelloTest)SpringContext.Context.GetObject("Hello");

test.Test();

//Test Spring & NHibernate

UserDao dao = SpringContext.Context.GetObject("UserDao") as UserDao;

User newUser = null;

try

{

newUser = dao.Load("joe_cool");

}

catch

{}

if(newUser==null)

{

newUser = new User();

newUser.Id = "joe_cool";

newUser.UserName = "Joseph Cool";

newUser.Password = "abc123";

newUser.EmailAddress = "joe@cool.com";

newUser.LastLogon = DateTime.Now;

// Tell NHibernate that this object should be saved

dao.SaveObject(newUser);

}

User joeCool = dao.Load("joe_cool");

// set Joe Cool's Last Login property

joeCool.LastLogon = DateTime.Now;

// flush the changes from the Session to the Database

dao.UpdateObject(joeCool);

IList recentUsers = dao.GetAllObjectsList();

foreach(User user in recentUsers)

{

//Assert.IsTrue(user.LastLogon > (new DateTime(2004, 03, 14, 20, 0, 0)) );

Console.WriteLine(user.UserName);

Console.WriteLine(user.Password);

}

Console.ReadLine();//让程序停留，回车关闭。

}

}

}

This is Spring.NET Sample Test!

Please press Enter close the windows!

Joseph Cool

abc123