C# : データベースを DataSet クラスで更新する / フィールドに値をセットして Update

更新の SQL を作成せずに、DataRow オブジェクトの中のフィールドに対して個別にデータをセットします。ここでは、 System.Data.SqlClient を使用していますが、OleDb や Odbc でも同じです。

▼ DataAdapter を使用した更新方法のサンプル
DataAdapter.Update(DataSet) Method
▼ 列にデータをセットする方法のサンプル
DataColumn Class
▼ 各オブジェクトの参照方法のサンプル
DataSet.Tables Property
▼ 接続からの全体像
DataSet Class
▼ DataSet 内の Table と言う名称について
複数のselect文をまとめて実行するには?
01.using System;
02.using System.Data;
03.using System.Data.SqlClient;
04. 
05.namespace DBUpdate1
06.{
07.        class Program
08.        {
09.                static void Main(string[] args)
10.                {
11.                        DataSet dataSet = new DataSet();
12.                        string connectionString;
13.                        string queryString = "select * from 社員マスタ where 社員コード = '0001'";
14. 
15.                        SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder();
16.                        // 接続用のパラメータを追加
17.                        builder.Add("Data Source", "layla");
18.                        builder.Add("Initial Catalog", "lightbox");
19.                        builder.Add("User ID", "sa");
20.                        builder.Add("Password", "");
21. 
22.                        // 接続文字列を取得
23.                        connectionString = builder.ConnectionString;
24. 
25.                        using (SqlConnection connection = new SqlConnection(connectionString))
26.                        {
27.                                // 接続
28.                                connection.Open();
29.                                SqlDataAdapter adapter = new SqlDataAdapter();
30.                                // 参照用のマップを追加
31.                                adapter.TableMappings.Add("Table", "社員マスタ");
32. 
33.                                // SQL 作成
34.                                SqlCommand command = new SqlCommand(queryString,connection);
35.                                command.CommandType = CommandType.Text;
36.                                adapter.SelectCommand = command;
37. 
38.                                // 更新用のオブジェクトを準備
39.                                SqlCommandBuilder commandBuilder = new SqlCommandBuilder(adapter);
40. 
41.                                // データを取り出す
42.                                adapter.Fill(dataSet);
43. 
44.                                // テーブルを取得
45.                                DataTable dataTable = dataSet.Tables["社員マスタ"];
46. 
47.                                // 行と列の数( ここでは行は 1 )
48.                                Console.WriteLine($"行数 : {dataTable.Rows.Count}");
49.                                Console.WriteLine($"列数 : {dataTable.Columns.Count}");
50. 
51.                                // 行
52.                                DataRow row = dataTable.Rows[0];
53. 
54.                                // 列の定義
55.                                DataColumn column = dataTable.Columns["氏名"];
56.                                Console.WriteLine($"氏名 : {column.DataType.ToString()}");
57.                                column = dataTable.Columns["給与"];
58.                                Console.WriteLine($"給与 : {column.DataType.ToString()}");
59.                                column = dataTable.Columns["手当"];
60.                                Console.WriteLine($"手当 : {column.DataType.ToString()}");
61.                                column = dataTable.Columns["生年月日"];
62.                                Console.WriteLine($"生年月日 : {column.DataType.ToString()}");
63. 
64.                                // 列の正確なデータの取り出し
65.                                string simei = row.Field<string>("氏名");
66.                                Console.WriteLine(simei);
67.                                int kyuyo = row.Field<int>("給与");
68.                                Console.WriteLine(kyuyo);
69.                                DateTime birth = row.Field<DateTime>("生年月日");
70.                                Console.WriteLine($"{birth.ToShortDateString()}");
71. 
72.                                // データのセット
73.                                row["氏名"] = "山田 太郎";
74.                                // 整数のセット
75.                                row["給与"] = 10000;
76.                                // NULL のセット
77.                                row["手当"] = DBNull.Value;
78.                                // 日付のセット
79.                                row["生年月日"] = DateTime.Parse("1999/01/02");
80. 
81.                                // 更新用のコマンドを取得
82.                                adapter.UpdateCommand = commandBuilder.GetUpdateCommand();
83.                                // 更新実行
84.                                adapter.Update(dataSet);
85.                        }
86. 
87.                        // 一時停止
88.                        Console.ReadLine();
89.                }
90.        }
91.}

更新の無い場合のデータ読み出し

接続準備等は同じなので、パラメータのセットの仕方を別バリエーションで行っています。
001.using System;
002.using System.Data.SqlClient;
003. 
004.namespace DBSelect
005.{
006.        class Program
007.        {
008.                static void Main(string[] args)
009.                {
010.                        string connectionString;
011.                        string queryString = "select * from 社員マスタ order by 社員コード";
012. 
013.                        SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder();
014.                        // 接続用のパラメータを追加
015.                        builder.Add("Data Source", "layla");
016.                        builder.Add("Initial Catalog", "lightbox");
017.                        builder.Add("User ID", "sa");
018.                        builder.Add("Password", "");
019. 
020.                        // 接続文字列を取得
021.                        connectionString = builder.ConnectionString;
022. 
023.                        using (SqlConnection connection = new SqlConnection(connectionString))
024.                        using (SqlCommand command = new SqlCommand())
025.                        {
026. 
027.                                // *********************
028.                                // 接続
029.                                // *********************
030.                                connection.Open();
031.                                // コマンドオブジェクトに接続をセット
032.                                command.Connection = connection;
033.                                // コマンドを通常 SQL用に変更
034.                                command.CommandType = System.Data.CommandType.Text;
035. 
036.                                // *********************
037.                                // 実行 SQL
038.                                // *********************
039.                                command.CommandText = queryString;
040. 
041.                                // *********************
042.                                // レコードセット取得
043.                                // *********************
044.                                using (SqlDataReader reader = command.ExecuteReader())
045.                                {
046. 
047.                                        // *********************
048.                                        // 列数
049.                                        // *********************
050.                                        int nCols = reader.FieldCount;
051. 
052.                                        // データ取得と表示
053.                                        int row_cnt = 0;
054.                                        while (reader.Read())
055.                                        {
056. 
057.                                                row_cnt++;
058. 
059.                                                // 初回のみ、タイトル文字列を設定
060.                                                if (row_cnt == 1)
061.                                                {
062.                                                        for (int idx = 0; idx < nCols; idx++)
063.                                                        {
064.                                                                Console.Write($"{reader.GetName(idx)}  ");
065.                                                        }
066.                                                        Console.WriteLine();
067.                                                }
068. 
069.                                                // 行データ
070.                                                for (int idx = 0; idx < nCols; idx++)
071.                                                {
072. 
073.                                                        // NULL でない場合
074.                                                        if (!reader.IsDBNull(idx))
075.                                                        {
076.                                                                // 列のデータ型を取得
077.                                                                Type fldType = reader.GetFieldType(idx);
078. 
079.                                                                // 文字列
080.                                                                if (fldType.Name == "String")
081.                                                                {
082.                                                                        Console.Write($"{reader.GetValue(idx).ToString()}  ");
083.                                                                }
084.                                                                else if (fldType.Name == "Int32")
085.                                                                {
086.                                                                        Console.Write($"{reader.GetInt32(idx)}  ");
087.                                                                }
088.                                                                else if (fldType.Name == "DateTime")
089.                                                                {
090.                                                                        Console.Write($"{reader.GetDateTime(idx).ToShortDateString()}  ");
091.                                                                }
092.                                                                else
093.                                                                {
094.                                                                        Console.Write($"{reader.GetValue(idx).ToString()}");
095.                                                                }
096. 
097.                                                        }
098.                                                }
099. 
100.                                                Console.WriteLine();
101. 
102.                                        }
103. 
104.                                        // リーダを使い終わったので閉じる
105.                                        reader.Close();
106. 
107.                                        connection.Close();
108.                                }
109. 
110.                        }       // 最外の using の終わり
111. 
112.                        Console.ReadLine();
113.                }
114.        }
115.}



C#, データベース

さくらインターネットの phpMyAdmin でテーブルを作成してデータを追加する

さくらインターネットでは、MySQL のバージョンによって、phpMyAdmin のバージョンにも違いがあります。

1) MySQL 5.5 : phpMyAdmin のバージョン : 3.3.10.5
2) MySQL 5.7 : phpMyAdmin のバージョン : 4.7.9

以降は、phpMyAdmin のバージョンが 4.7.9 のサンプルです

▼ テーブルの作成は以下の SQL を実行すると可能ですが、phpMyAdmin を使用すれば対話式で作成ができます。
1.create table `クラス名称` (
2.        `コード` varchar(4)
3.        ,`名称` varchar(100)
4.        ,`担当` varchar(20)
5.        ,primary key(`コード`)
6.)

▼ MySQL のバージョン表示をコンソールから行えます


▼ テーブル作成画面です


▼ 新規行の入力画面です


ツリーからテーブルを選択すると現在のデータが表示されるので、編集からさらに新規データを作成する事もできます




1.INSERT INTO `クラス名称`(`コード`, `名称`, `担当`) VALUES (':value1',':value2',':value3')

データをバインドさせて SQLを実行

SQL のデータ部分に :(コロン) を前に付加した変数を用意すると、バイントのチェックボックスによって入力フィールドが現れます。





VBScript で 32ビット ODBC ドライバの一覧を取得する( ODBC 接続のドライバ文字列を正しく取得したい )

Windows でデータベースに接続する際、ODBC データソースに登録せずに動的に利用する場合には、ドライバの正しい文字列が必要になリます。レジストリエディタで参照すればいいのですが、結構面倒なのでこのスクリプトを使えばすぐ取り出せます。

最初の『管理者として cscript 実行を強制する』は、cscript での実行を強制するついでに実装しています。(なんらかの制限環境でも動くようにとの考慮です。)

目的は、レジストリのキーの一覧ですが、キーの一覧は知る限り、WMI でしか取得できないので、GetObject("Winmgmts:root\default:StdRegProv") でレジストリ処理用のオブジェクトを取得して使用します。

一覧表示は、cscript で実行を強制しているので単純に Wscript.Echo で出力。コマンドプロンプトを新たに作成して実行するので、結果の表示を止めるために、Wscript.StdIn.ReadLine です。
01.' 管理者として cscript 実行を強制する
02.Set obj = Wscript.CreateObject("Shell.Application")
03.if Wscript.Arguments.Count = 0 then
04.        obj.ShellExecute "cscript.exe", WScript.ScriptFullName & " runas", "", "runas", 1
05.        Wscript.Quit
06.end if
07. 
08.const WMI_HKEY_LOCAL_MACHINE = &H80000002
09. 
10.Set objRegistry = GetObject("Winmgmts:root\default:StdRegProv")
11. 
12.strBasePath = "SOFTWARE\Wow6432Node\ODBC\ODBCINST.INI"
13. 
14.Call objRegistry.EnumKey( WMI_HKEY_LOCAL_MACHINE, strBasePath, aKeys )
15. 
16.For Each strKeyPath in aKeys
17.        Wscript.Echo strKeyPath
18.Next
19. 
20.Wscript.StdIn.ReadLine

実際はいくつか変なのが混じっていますが ODBC 接続のドライバ文字列が欲しい場合を想定しているので、その場合はそれは排除して見れると思います。



※ コマンドプロンプトのプロパティで、簡易編集モードを ON にして、範囲をドラッグして右クリックでコピーできます。

※ コマンドプロンプトならば、『reg query HKLM\SOFTWARE\Wow6432Node\ODBC\ODBCINST.INI』ですから、リダイレクトしてファイルに表示結果を書き込めばいいでしょう( 但し、キーが全て表示されるのでとても見にくいです )
reg query HKLM\SOFTWARE\Wow6432Node\ODBC\ODBCINST.INI > list.txt

PHP で MySQL のクエリテストする為のコード( Bootstrap 仕様 )

$_GET['text'] で入力された SQL が引き渡されます。
※ GET コマンドなので、IE11 以外ならば SQLは アドレスバーで直接入力ができると思います。
※ php-mysql-test.php?text=SQL文

テーブルの表現には Bootstrap を使用しています( 一応スマホではテーブル部分のみ横スクロールします )

QueryString に text が無い場合と text に有効な文字が全く無い場合は  show variables でシステム変数の一覧を表示します
001.<?php
002.// キャッシュを使用しない
003.session_cache_limiter('nocache');
004.session_start();
005. 
006.// UTF-8
007.header( "Content-Type: text/html; charset=utf-8" );
008. 
009.?>
010.<!DOCTYPE html>
011.<html>
012.<head>
013.<meta charset="utf-8">
014.<meta content="width=device-width initial-scale=1.0 minimum-scale=1.0 maximum-scale=1.0 user-scalable=no" name="viewport">
015.<title>SQL実行結果</title>
016.<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/twitter-bootstrap/4.3.1/css/bootstrap.css" />
017.<style>
018./*
019.罫線等のテーブルのレイアウトは、Bootstrap にて適用
020.table {
021.        border: solid 1px #000;
022.        border-collapse: collapse;
023.}
024. 
025.th,td {
026.        border: solid 1px #000;
027.        padding: 5px;
028.}
029.*/
030.</style>
031.</head>
032.<body>
033.<!-- Bootstrap の alert でタイトル -->
034.<div class="alert alert-dark">
035.        MySQL Query TEST
036.</div>
037. 
038.<?php
039.if ( !isset( $_GET['text'] ) || trim($_GET['text']) == "" ) {
040.        // クエリ初期値は システム変数一覧
041.        $_GET['text'] = "show variables";
042.}
043. 
044.// P で挟んだデータの出力
045.print_cell_html( "p", $_GET['text'] );
046. 
047.$server = 'localhost';
048.$dbname = 'lightbox';
049.$user = 'root';
050.$password = 'パスワード';
051. 
052.// ***************************
053.// 接続
054.// ***************************
055.$mysqli = @ new mysqli($server, $user, $password, $dbname);
056.if ($mysqli->connect_error) {
057.        print "接続エラーです : ({$mysqli->connect_errno}) ({$mysqli->connect_error})";
058.        exit();
059.}
060. 
061.// ***************************
062.// クライアントの文字セット
063.// ***************************
064.$mysqli->set_charset("utf8");
065. 
066.// ***************************
067.// クエリ
068.// ***************************
069.$result = $mysqli->query($_GET['text']);
070.if ( !$result ) {
071.        print "\n";
072.        print "<span style='color:#f00'>error : " . $mysqli->error . "</span>";
073.        exit();
074.}
075. 
076.// ***************************
077.// 列数
078.// ***************************
079.$nfield = $result->field_count;
080.if ( $nfield ) {
081.        $ncount = 0;
082.        print "<div class='table-responsive-sm'>";
083.        print "<table class='table table-bordered table-hover'><thead class='thead-dark'>\n";
084. 
085.        // 行番号用タイトル
086.        print "\t<th></th>";
087. 
088.        // 列のタイトルを作成
089.        $field = $result->fetch_fields( );
090.        for( $i = 0; $i < $nfield; $i++ ) {
091. 
092.                // TH で挟んだデータの出力
093.                print_cell_html( "th", $field[$i]->name );
094. 
095.        }
096. 
097.        print "</thead>\n<tbody>\n";
098. 
099.        // ***************************
100.        // 行データ
101.        // ※ 結果の行を数値添字配列で取得
102.        // ***************************
103.        while ($row = $result->fetch_row()) {
104. 
105.                print "<tr>\n\t";
106.                // 行番号
107. 
108.                // TDで挟んだデータの出力
109.                print_cell_html( "td", ($ncount + 1) );
110. 
111.                for( $i = 0; $i < $nfield; $i++ ) {
112. 
113.                        // TDで挟んだデータの出力
114.                        print_cell_html( "td", $row[$i] );
115. 
116.                }
117.                print "\n</tr>\n";
118. 
119.                // 行番号
120.                $ncount++;
121.        }
122. 
123.        print "</tbody></table>";
124.        print "</div>";
125. 
126.}
127. 
128.// ***************************
129.// 接続解除
130.// ***************************
131.$mysqli->close();
132. 
133. 
134.// ***************************
135.// セルの HTML 出力関数
136.// ***************************
137.function print_cell_html( $html, $data ) {
138. 
139.print <<<CELL_HTML
140.<{$html}>{$data}</{$html}>
141.CELL_HTML;
142. 
143.}
144. 
145.?>
146. 
147.</body>
148.</html>



Pleiades Ultimate の XAMPP 内の MySQL を利用可能にしてテストデータを登録する

xampp-control.exe の設定

xampp-control.exe は管理者権限で実行する必要があるので、エクスプローラから右クリックしてプロパティの『互換性』タブで管理者として実行するチェックを ON にします。



my.ini の設定( サーバーをUTF-8 に設定 )



C:\pleiades\xampp\mysql\bin\my.ini の以下の部分のコメントを削除します。



開発用のソフトウェアを準備

SQLの窓 Build C++ と、販売管理C でテスト環境を構築します 。

手順1 ( MySQL の ODBC ドライバ)

SQLの窓 Build C++ は 32ビットアプリケーションなので、まず MySQL の ODBC ドライバ(32ビット)をダウンロードしてインストールします。

Connector/ODBC 5.3

※ 何も選択せずにダイアログ内で進めればOK です
Visual Studio 2013 の Visual C++ 再頒布可能パッケージ

Connector/ODBC 8.0
Microsoft Visual C++ 2015 再頒布可能パッケージ Update 3


手順2 (SQLの窓 Build C++)

次に、SQLの窓 Build C++ をダウンロードして解凍して WinOfSql.exe を実行して下さい。

※ レジストリは使用しません。
※ 複数のフォルダにいくつあっても動作します。
※ 削除すればアンインストールです。

実行後 M ボタンをクリックして MySQL 接続用のダイアログを開き、ODBC アドミニストレータボタンで ODBC の DSN を作成する Windows の管理ツール(32ビット) を実行します。



手順3 ( DSN 登録 )

ここで、xampp-control.exe を実行し、開始ボタンで MySQL を開始します。(初期設定なので失敗しないようにこのタイミングで実行しています / 以降は必要な時でいいです)



ユーザDSN => 追加 => MySQL ODBC 5.3 Unicode Driver

( ODBC32ビットドライバの一覧は、HKEY_LOCAL_MACHINE\SOFTWARE\WOW6432Node\ODBC\ODBCINST.INI より確認できます)

▼ Details ボタンで全て開いて Character Set で cp932 を選択して下さい。


データベースは、まだユーザ用を作成していないので mysql を選択します。これは後で変更しなくとも、接続時に変更しますのでこのままでいいです。

入力が終わったら、データベースの右の Test ボタンで接続が成功するのを確認します。接続に成功したら、OK で登録します。

手順4 ( SQLの窓 Build C++ で接続して DB 作成 )



M ボタンで接続ダイアログを表示して、DSN に登録した情報で接続します



右側のテキストエリアで create database 自分用のデータベース名 で、Action ボタンをクリックして作成します。





作成後は、いったん終了して再度 SQLの窓 Build C++ を実行します(オペミスを防ぐためです)。そして再度 M ボタンで、今度は作成したデータベース(ここでは lightbox)で接続します。( 接続情報を保存する為です )




手順5 ( 作成した データーベース の確認 )

接続後、テーブルが無いのでなにも表示されませんが、メニューに登録済みの SQL で内容を確認できます。

『データベース一覧』で、登録したデータベースと既に存在するデータベースを確認できます。





『システム変数の値』で、キャラクタセットを確認します





手順6 ( 販売管理C.mdb をインポート )

▼ 学習用 MDB データのダウンロード


解凍した中にある 販売管理C.mdb を SQLの窓 Build C++ の左側のリストにドラッグ&ドロップします。



次にリストの中のテーブルを、SHIFTキーを使って選択して(まず先頭をクリックして、SHIFTキーを押しながら最後をクリック)から、処理 => エクスポート => MySQL を選択



直前の接続が選択されているので、下欄のチェックボックスを二つ選択して実行します


※ チェックボックスが無いと、主キーが無い状態でデータのみがエクスポートされます( 後からキー設定は可能ですがテーブルを全て設定するのは面倒です )

完了すると左下にメッセージが出るので、x ボタンで閉じます。



閉じたら、そこは MDB の接続なので、M ボタンで切り替えて下さい。テーブルの一覧が表示されるはずです。

※ テーブルをダブルクリックすると、テーブルデータが表示されて直接変更が可能です。( 更新は 『編集』メニューから更新です )







関連する記事

Pleiades Eclipse 4.7 Oxygen 2 Windows 64bit Ultimate Full Edition のインストールといろいろな準備


Pleiades Oxygen 2 の XAMPP 内の FileZilla Server をインストールして使用する


Pleiades Eclipse 4.7 Oxygen で Python を使って MySQL にアクセスする





SQLServer : 前月データを抽出する条件

まず、dateadd と datepart の機能を確認する為の SQL が以下のようになります。

※ m と mm は month の省略形です
01.select
02.        cast('2019/01/01' as datetime),
03.        dateadd(month, -1, getdate()),
04.        dateadd(m, -1, getdate()),
05.        dateadd(mm, -1, getdate()),
06. 
07.        case
08.        when datepart(year, cast('2019/01/01' as datetime)) = datepart(year, dateadd(month, -1, getdate()))
09.                then '一致しました'
10.                else '一致しません'
11.        end as 年比較,
12. 
13.        case
14.        when datepart(month, cast('2019/01/01' as datetime)) = datepart(month, dateadd(month, -1, getdate()))
15.                then '一致しました'
16.                else '一致しません'
17.        end as 月比較

▼ これを踏まえて条件にしたものです。
1.select *
2. 
3.from [テーブル名]
4. 
5.where
6.        DATEPART(year, 対象日付) = DATEPART(year, DATEADD(m, -1, GETDATE()))
7.and     DATEPART(m, 対象日付) = DATEPART(m, DATEADD(m, -1, GETDATE()))

現在の年月日を getdate() で取得し、その月を一つマイナスして年部分と月部分を別々に取得して、比較したい日付の年部分と月部分がどちらも一致していたら、前月です。


関連する Microsoft ドキュメント

DATEADD (Transact-SQL)

DATEPART (Transact-SQL)

CAST および CONVERT (Transact-SQL)

CASE (Transact-SQL)




Microsoft® SQL Server® Express のダウンロードとインストール

Microsoft® SQL Server® 2012 Express
Microsoft® SQL Server® 2014 Express
Microsoft® SQL Server® 2016 Service Pack 2 Express
Microsoft® SQL Server® 2017 Express

バージョン、エディション、および SQL Server の更新プログラム レベルとそのコンポーネントを確認する方法

以下は Microsoft® SQL Server® 2012 Express をインストール時のキャプチャです


















参考情報

SQLExpress 2005( および 2008 ) の接続設定