MFCでDBテーブルを操作したい話　４(最終回)

void CMySQLTest1Dlg::OnBnClickedButton1()
{
	sql::SQLString strHost = "tcp://127.0.0.1:3306";	// ホスト名
	sql::SQLString strUser = "root";					// ユーザ名
	sql::SQLString strPass = "password";				// パスワード
	// ※パスワードは、前回設定したものを入れる

	try
	{
		// MySQLドライバのインスタンス取得
		sql::mysql::MySQL_Driver* driver = sql::mysql::get_mysql_driver_instance();

		// DB接続情報を設定。
		std::unique_ptr<sql::Connection> con(driver->connect(strHost, strUser, strPass));

		//ここまで来たら、接続できた
		AfxMessageBox(_T("接続成功"));
	}
	catch (sql::SQLException& e)
	{
		// 接続できなかった
		CString errorMessage = _T("");
		errorMessage.Format(_T("エラー: %s\r\nエラーコード: %d"), CString(e.what()), e.getErrorCode());
		AfxMessageBox(errorMessage, MB_OK | MB_ICONERROR);
	}
}

void CMySQLTest1Dlg::OnBnClickedButton1()
{
	sql::SQLString strHost = "tcp://127.0.0.1:3306";	// ホスト名
	sql::SQLString strUser = "root";					// ユーザ名
	sql::SQLString strPass = "password";         		// パスワード
	// ※パスワードは、前回設定したものを入れる

		try
	{
		// MySQLドライバのインスタンス取得
		sql::mysql::MySQL_Driver* driver = sql::mysql::get_mysql_driver_instance();
		//sql::SQLString strOpt = "SET NAMES utf8mb4";

		// DB接続情報を設定。
		std::unique_ptr<sql::Connection> con(driver->connect(strHost, strUser, strPass));

		//ここまで来たら、接続できた
		//AfxMessageBox(_T("接続成功"));
		//con->setClientOption("OPT_CHARSET_NAME", "utf8mb4"); // これでクライアント側の文字セットを設定
		// スキーマを設定
		con->setSchema("testschema1");

		// クエリを実行
		std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("SELECT name FROM testtable1 WHERE id = ?"));
		pstmt->setInt(1, 1);

		std::unique_ptr<sql::ResultSet> res(pstmt->executeQuery());

		CString strDisp = _T("");	// 表示用
		// 結果を処理
		if (res->next()) 
		{
			do
			{
				std::string name = res->getString("name");
				// UTF-8からUTF-16への変換
				int len = MultiByteToWideChar(CP_UTF8, 0, name.c_str(), -1, NULL, 0);
				if (len > 0)
				{
					std::wstring wideName(len, 0);
					MultiByteToWideChar(CP_UTF8, 0, name.c_str(), -1, &wideName[0], len);

					// std::wstringからCStringに変換
					CString cstrName(wideName.c_str());
					strDisp += cstrName;
					strDisp += _T("\r\n");
				}
				else
				{
					strDisp =_T("UTF - 8からUTF - 16への変換に失敗しました。");
					break;
				}
			} while (res->next());
		}
		else 
		{
			strDisp = _T("idが1のデータが見つかりませんでした。");
		}

		AfxMessageBox(strDisp, MB_OK | MB_ICONINFORMATION);
	}
	catch (sql::SQLException& e)
	{
		// 接続できなかった
		CString errorMessage = _T("");
		errorMessage.Format(_T("エラー: %s\r\nエラーコード: %d"), CString(e.what()), e.getErrorCode());
		AfxMessageBox(errorMessage, MB_OK | MB_ICONERROR);
	}
}

SELECT name FROM testtable1 WHERE id = 1;

     　 // クエリを実行
		std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("SELECT name FROM testtable1 WHERE age = ?"));
		pstmt->setInt(1, 20);

	// クエリを実行
	std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("INSERT INTO testtable1 VALUES (?, ?, ?)"));
	pstmt->setInt(1, 25);
	pstmt->setString(2, "Mike Davis");
	pstmt->setInt(3, 70);

	//std::unique_ptr<sql::ResultSet> res(pstmt->executeQuery());
	pstmt->executeUpdate();

	/*
	CString strDisp = _T("");	// 表示用
	// 結果を処理
	if (res->next()) 
	{
		// 略
	}
	else 
	{
		// 略
	}
	*/

	// クエリを実行	
	std::unique_ptr<sql::PreparedStatement> pstmt(con->prepareStatement("DELETE FROM testtable1 WHERE id = ?"));
	pstmt->setInt(1, 11);
	pstmt->executeUpdate();