//---------------------------------------------------------------- // <copyright file="SqlController.cs" company="Microsoft"> // Copyright (c) Microsoft Corporation. All rights reserved. // </copyright> //---------------------------------------------------------------- namespace QuickAnswer { using System; using System.Collections; using System.Data; using System.Data.Common; using System.Data.SqlClient; using System.Xml; /// <summary> /// DBアクセス SQLの実行クラス /// </summary> public sealed class SqlController : IDisposable { /// <summary> /// コネクション オブジェクト /// </summary> private SqlConnection sqlConnection; /// <summary> /// トランザクション オブジェクト /// </summary> private SqlTransaction sqlTransaction; /// <summary> /// Reader 保持フィールド. /// </summary> private ArrayList readers = new ArrayList(); /// <summary> /// SqlCommandTimeout Field /// </summary> private int? commandTimeout = null; /// <summary> /// Initializes a new instance of the SqlController class /// </summary> /// <param name="connectionString">Database 接続文字列</param> public SqlController(string connectionString) { this.sqlConnection = new SqlConnection(); this.sqlConnection.ConnectionString = connectionString; this.sqlConnection.Open(); } /// <summary> /// Gets or sets SqlCommandのタイムアウト時間 /// </summary> public int? SqlCommandTimeOut { get { return this.commandTimeout; } set { this.commandTimeout = value; } } /// <summary> /// トランザクション の開始 /// </summary> /// <returns>SqlTransaction オブジェクト</returns> public SqlTransaction BeginTransaction() { this.sqlTransaction = this.sqlConnection.BeginTransaction(); return this.sqlTransaction; } /// <summary> /// SQLを実行し、 DBからデータを取得. /// </summary> /// <param name="sqlCommand">SQL Command Class</param> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <param name="commandType">SqlCommandType Text or StoredProcedure</param> /// <returns>SqlDataReader の返却</returns> public SqlDataReader ExecuteReader( SqlCommand sqlCommand) { SqlDataReader sqlDataReader = sqlCommand.ExecuteReader(); this.readers.Add(sqlDataReader); return sqlDataReader; } /// <summary> /// SQLを実行し、DBからデータを取得. /// 1行1列目の値を返します。結果セットの行が0行の場合、nullを返します。 /// </summary> /// <param name="sqlCommand">SQL Command Class</param> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <param name="commandType">SqlCommandType Text or StoredProcedure</param> /// <returns>1行1列目 の値を取得する</returns> public static object ExecuteScalar( SqlCommand sqlCommand) { using (SqlDataReader sqlDataReader = sqlCommand.ExecuteReader()) { if (!sqlDataReader.HasRows) { return null; } sqlDataReader.Read(); return sqlDataReader[0]; } } /// <summary> /// SQLを実行し、DBからデータを取得. /// 結果セットが存在しない場合は、空のDataTableを返却します. /// </summary> /// <param name="sqlCommand">SQL Command Class</param> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <param name="commandType">SqlCommandType Text or StoredProcedure</param> /// <returns>DataTable を返却する</returns> public DataTable ExecuteDataTable( SqlCommand sqlCommand) { SqlDataReader sqlDataReader = this.ExecuteReader(sqlCommand); DataTable dt = new DataTable(); if (sqlDataReader.HasRows) { dt.Load(sqlDataReader); } return dt; } /// <summary> /// SQLを実行し、DBからデータを取得. /// 結果セットが存在しない場合は、空のDataSetを返却します. /// </summary> /// <param name="sqlCommand">SQL Command Class</param> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <param name="commandType">SqlCommandType Text or StoredProcedure</param> /// <returns>DataSet を返却する</returns> public static DataSet ExecuteDataSet( SqlCommand sqlCommand) { using (SqlDataAdapter adapter = new SqlDataAdapter(sqlCommand)) { DataSet ds = new DataSet(); adapter.Fill(ds); return ds; } } /// <summary> /// SQLを実行し、 XML形式のデータを取得. /// </summary> /// <param name="sqlCommand">SQL Command Class</param> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <param name="commandType">SqlCommandType Text or StoredProcedure</param> /// <returns>XmlReader を返却する</returns> public XmlReader ExecuteXmlReader( SqlCommand sqlCommand) { XmlReader xmlReader = sqlCommand.ExecuteXmlReader(); this.readers.Add(xmlReader); return xmlReader; } /// <summary> /// Execute Non Queryを実行する. /// </summary> /// <param name="sqlCommand">SQL Command Class</param> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <param name="commandType">SqlCommandType Text or StoredProcedure</param> /// <returns>影響を受けた行数の カウント</returns> public static int ExecuteNonQuery( DbCommand sqlCommand) { return sqlCommand.ExecuteNonQuery(); } /// <summary> /// リソース の解放を行う. /// </summary> public void Dispose() { // ReaderのClose. for (IEnumerator ie = this.readers.GetEnumerator(); ie.MoveNext();) { if (ie.Current is SqlDataReader) { ((SqlDataReader)ie.Current).Close(); } if (ie.Current is XmlReader) { ((XmlReader)ie.Current).Close(); } } this.readers = new ArrayList(); // Transactionの破棄. if (this.sqlTransaction != null) { this.sqlTransaction.Dispose(); this.sqlTransaction = null; } // Connectionの返却. if (this.sqlConnection != null) { this.sqlConnection.Close(); this.sqlConnection = null; } } /// <summary> /// SqlCommand の生成. /// </summary> /// <param name="sqlParameters">埋め込み パラメータ一覧</param> /// <returns>SqlCommand の返却</returns> public SqlCommand GetSqlCommand( SqlParameter[] sqlParameters) { // SqlCommandの生成 SqlCommand sqlCommand = new SqlCommand(); sqlCommand.CommandType = CommandType.StoredProcedure; //sqlCommand.CommandText = commandText; sqlCommand.Connection = this.sqlConnection; if (this.commandTimeout != null) { sqlCommand.CommandTimeout = (int)this.commandTimeout; } if (this.sqlTransaction != null) { sqlCommand.Transaction = this.sqlTransaction; } if (sqlParameters != null) { foreach (SqlParameter sqlParameter in sqlParameters) { sqlCommand.Parameters.Add(sqlParameter); } } return sqlCommand; } } }
调用：
using (SqlController sqlCon = new SqlController(strConn)) { // パラメーターを設定 SqlParameter[] sqlParameter = { new SqlParameter("@PrmBrand", brand), new SqlParameter("@PrmModel", model), new SqlParameter("@PrmFMCModelTypeCode", fmcModelTypeCode) }; // SQLを実行し、 DBからデータを取得 SqlCommand sqlCommand = sqlCon.GetSqlCommand(sqlParameter); sqlCommand.CommandText = "spIFWSearchCatalogCarsByBrandModelFmc"; using (SqlDataReader sqlReader = sqlCon.ExecuteReader(sqlCommand)) { if (sqlReader.Read()) { do { CatalogCarGrade catalogCar = new CatalogCarGrade(); catalogCar.MakerCode = AutosServiceUtil.GetString(sqlReader["BrandCode"]); } } }
//---------------------------------------------------------------- // <copyright file="SqlCommandType.cs" company="Microsoft"> // Copyright (c) Microsoft Corporation. All rights reserved. // </copyright> //---------------------------------------------------------------- namespace QuickAnswer { /// <summary> /// Sql コマンドタイプ /// </summary> public enum SqlCommandType { /// <summary> /// クエリ指定 /// Text /// </summary> Text, /// <summary> /// ストアドプロシージャ指定 /// StoredProcedure /// </summary> StoredProcedure, } }