NHibernate 操作原生SQL以及查询DataTable，DataSet

1.         public void ExecuteNonQuery(string sql)
2.         {
3.             ISession session = null;
4.             ITransaction transaction = null;
5.             try
6.             {
7.                 session = SessionHelper.OpenSession();
8.                 transaction = session.BeginTransaction();
9.                 IDbCommand command = session.Connection.CreateCommand();
10.                 transaction.Enlist(command);
11.                 command.CommandText = sql;
12.                 command.ExecuteNonQuery();
14.                 transaction.Commit();
15.             }
16.             catch (Exception ex)
17.             {
18.                 if (transaction != null)
19.                 {
20.                     transaction.Rollback();
21.                 }
22.                 throw ex;
23.             }
24.             finally
25.             {
26.                 if (session != null)
27.                 {
28.                     session.Close();
29.                 }
30.             }
31.         }

1.         public DataSet ExecuteDataset(string sql)
2.         {
3.             ISession session = null;
4.             DataSet ds = new DataSet();
5.             try
6.             {
7.                 session = SessionHelper.OpenSession();
8.                 IDbCommand command = session.Connection.CreateCommand();
9.                 command.CommandText = sql;
11.                 IDataReader reader = command.ExecuteReader();
12.                 DataTable result = new DataTable();
13.                 DataTable schemaTable = reader.GetSchemaTable();
14.                 for (int i = 0; i < schemaTable.Rows.Count; i++)
15.                 {
16.                     result.Columns.Add(schemaTable.Rows[i][0].ToString());
17.                 }
18.                 while (reader.Read())
19.                 {
20.                     int fieldCount = reader.FieldCount;
21.                     object[] values = new Object[fieldCount];
22.                     for (int i = 0; i < fieldCount; i++)
23.                     {
24.                         values[i] = reader.GetValue(i);
25.                     }
26.                     result.Rows.Add(values);
27.                 }
28.                 ds.Tables.Add(result);
29.             }
30.             catch (Exception ex)
31.             {
32.                 Debug.Assert(false);
33.             }
34.             finally
35.             {
36.                 if (session != null)
37.                 {
38.                     session.Close();
39.                 }
40.             }
41.             return ds;
42.         }