MFCで物品購入承認システム作成　３

#pragma once
#include <mysql/jdbc.h>

class CMySQLManager
{
private:
	// DB接続関連
	const sql::SQLString HOST = "tcp://127.0.0.1:3306";
	const sql::SQLString USER = "root";
	const sql::SQLString PASSWORD = "password";	//自分の接続パスワード

	//スキーマ
	const sql::SQLString SCHEMA = "supply_request";
	//テーブル
	const sql::SQLString TABLE_USER = "user";
	const sql::SQLString TABLE_GROUP = "group";
	const sql::SQLString TABLE_KOUMOKU = "koumoku";
	const sql::SQLString TABLE_RECORD = "record";

	// 接続状況
	std::shared_ptr<sql::Connection> m_con;

public:
	// コンストラクタ
	CMySQLManager();
	// デストラクタ
	~CMySQLManager();

	//接続
	std::shared_ptr<sql::Connection> GetConnection();

private:
	// エラーひとまとめ
	void ErrSQLException(sql::SQLException& e);
	// CString→SQLString変換処理
	sql::SQLString strConverter(CString str);
	// UTF8→UTF16変換処理
	CString strConvertFromUTF8ToUTF16(sql::SQLString strCol);

};

#include "pch.h"
#include "SupplyRequestManager.h"
#include "MySQLManager.h"

/**
 * @fn
 * @brief	コンストラクタ
 * @param	なし
 * @return	なし
 */
CMySQLManager::CMySQLManager()
{
    
}

/**
 * @fn
 * @brief	デストラクタ
 * @param	なし
 * @return	なし
 */
CMySQLManager::~CMySQLManager()
{
    // デストラクタで接続をクローズ
    if (m_con && m_con->isClosed() == false)
    {
        m_con->close();
    }
}

/**
 * @fn
 * @brief	エラー関連処理
 * @param	SQLException& e     エラー情報
 * @return	なし
 */
void CMySQLManager::ErrSQLException(sql::SQLException& e)
{
    //接続できなかったため、エラーを表示させる
    CString errorMessage = _T("");
    errorMessage.Format(_T("エラー: %s\r\nエラーコード: %d"), CString(e.what()), e.getErrorCode());
    AfxMessageBox(errorMessage, MB_OK | MB_ICONERROR);
}

/**
 * @fn
 * @brief	SQLString変換処理
 * @param	CString     str     変換前
 * @return	SQLString           変換後
 */
sql::SQLString CMySQLManager::strConverter(CString str)
{
    CT2CA pszConvertedAnsiString(str);
    std::string strStd(pszConvertedAnsiString);
    sql::SQLString sqlStrUserID(strStd);

    return sqlStrUserID;
}

/**
 * @fn
 * @brief	テーブルから取得したデータをUTF16に変換
 * @param	SQLString       strCol      変換前
 * @return	CString                     変換後
 */
CString CMySQLManager::strConvertFromUTF8ToUTF16(sql::SQLString strCol)
{
    CString strRtn = _T("");
    int len = MultiByteToWideChar(CP_UTF8, 0, strCol.c_str(), -1, NULL, 0);
    if (len > 0)
    {
        std::wstring wideName(len, 0);
        MultiByteToWideChar(CP_UTF8, 0, strCol.c_str(), -1, &wideName[0], len);
        // std::wstringからCStringに変換
        CString cstrCol(wideName.c_str());
        strRtn = cstrCol;
    }

    return strRtn;
}

/**
 * @fn
 * @brief	MySQL接続処理
 * @param	なし
 * @return	m_con
 */
std::shared_ptr<sql::Connection> CMySQLManager::GetConnection()
{
    if (!m_con || m_con->isClosed())
    {
        try
        {
            sql::mysql::MySQL_Driver* driver = sql::mysql::get_mysql_driver_instance();

            // 新しい接続を作成
            m_con = std::shared_ptr<sql::Connection>(driver->connect(HOST, USER, PASSWORD));
        }
        catch (sql::SQLException& e)
        {
            // 接続でエラーが生じた
            ErrSQLException(e);
        }
    }

    return m_con;
}