C# SQL Serverに接続してUPDATE・INSERT・DELETE文を直接実行する

このサイトはプロモーションを含みます

2024年9月14日

C#を使用してデータベース操作を行う際、SQL Serverは広く使用されているデータベース管理システムの一つです。特に、データの更新（UPDATE）、挿入（INSERT）、削除（DELETE）といった基本的な操作は、多くのアプリケーションで必要不可欠です。この記事では、C#からSQL Serverに接続し、これらの操作を直接実行する方法を、初心者にも分かりやすく解説します。

SQL Serverへの接続と基本的な操作

C#でSQL Serverに接続し、UPDATE、INSERT、DELETE文を実行するための基本的な手順は以下の通りです：

接続文字列の準備
データベース接続の確立
SQLコマンドの作成
SQLの実行
結果の確認

以下に、これらの手順を実装した基本的なコード例を示します：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "Data Source=YourServerName;Initial Catalog=YourDatabaseName;User ID=YourUsername;Password=YourPassword;";

        try
        {
            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                connection.Open();
                Console.WriteLine("データベースに接続しました。");

                // INSERT文の例
                string insertSql = "INSERT INTO Employees (FirstName, LastName) VALUES (@FirstName, @LastName)";
                using (SqlCommand insertCommand = new SqlCommand(insertSql, connection))
                {
                    insertCommand.Parameters.AddWithValue("@FirstName", "John");
                    insertCommand.Parameters.AddWithValue("@LastName", "Doe");
                    int insertedRows = insertCommand.ExecuteNonQuery();
                    Console.WriteLine($"{insertedRows}行挿入されました。");
                }

                // UPDATE文の例
                string updateSql = "UPDATE Employees SET FirstName = @NewFirstName WHERE LastName = @LastName";
                using (SqlCommand updateCommand = new SqlCommand(updateSql, connection))
                {
                    updateCommand.Parameters.AddWithValue("@NewFirstName", "Jane");
                    updateCommand.Parameters.AddWithValue("@LastName", "Doe");
                    int updatedRows = updateCommand.ExecuteNonQuery();
                    Console.WriteLine($"{updatedRows}行更新されました。");
                }

                // DELETE文の例
                string deleteSql = "DELETE FROM Employees WHERE LastName = @LastName";
                using (SqlCommand deleteCommand = new SqlCommand(deleteSql, connection))
                {
                    deleteCommand.Parameters.AddWithValue("@LastName", "Doe");
                    int deletedRows = deleteCommand.ExecuteNonQuery();
                    Console.WriteLine($"{deletedRows}行削除されました。");
                }
            }
        }
        catch (SqlException e)
        {
            Console.WriteLine("SQLエラー: " + e.Message);
        }
        catch (Exception e)
        {
            Console.WriteLine("エラー: " + e.Message);
        }
    }
}