「Qtの基礎 - データベース」の版間の差分

ナビゲーションに移動 検索に移動

Qtの基礎 - データベース (ソースを閲覧)

2024年8月14日 (水) 08:17時点における版

2,216 バイト追加 、 2024年8月14日 (水)
→‎MariaDB
79行目: 79行目:
   
   
  #include <QtSql>
  #include <QtSql>
#include <QString>
#include <QSqlError>
#include <stdexcept>
  #include <QDebug>
  #include <QDebug>
class DatabaseException : public std::runtime_error
{
public:
    DatabaseException(const QString& message) : std::runtime_error(message.toStdString()) {}
};
   
   
  class DatabaseManager
  class DatabaseManager
93行目: 102行目:
     bool updateRecord(int id, const QString &name, int age);
     bool updateRecord(int id, const QString &name, int age);
     bool deleteRecord(int id);
     bool deleteRecord(int id);
     void readAllRecords();
     QList<QMap<QString, QVariant>> readAllRecords();
   
   
  private:
  private:
     QSqlDatabase db;
     QSqlDatabase db;
    void checkConnection();
    void handleDatabaseError(const QString &operation, const QSqlError &error);
  };
  };
  </syntaxhighlight>
  </syntaxhighlight>
123行目: 134行目:
  {
  {
     if (!db.open()) {
     if (!db.open()) {
       qDebug() << "Error: connection with database failed";
       throw DatabaseException("Failed to open database connection: " + db.lastError().text());
      return false;
    }
    else {
      qDebug() << "Database: connection ok";
      return true;
     }
     }
    qDebug() << "Database connection opened successfully";
  }
  }
   
   
135行目: 143行目:
  void DatabaseManager::closeConnection()
  void DatabaseManager::closeConnection()
  {
  {
     db.close();
     if (db.isOpen()) {
      db.close();
      qDebug() << "Database connection closed";
    }
}
// 接続の確認
void DatabaseManager::checkConnection()
{
    if (!db.isOpen()) {
      throw DatabaseException("Database connection is not open");
    }
}
// エラーハンドリング処理
void DatabaseManager::handleDatabaseError(const QString &operation, const QSqlError &error)
{
    QString errorMessage = QString("%1 failed: %2").arg(operation, error.text());
    throw DatabaseException(errorMessage);
  }
  }
   
   
141行目: 167行目:
  bool DatabaseManager::createTable()
  bool DatabaseManager::createTable()
  {
  {
    checkConnection();
     QSqlQuery query;
     QSqlQuery query;
     query.prepare("CREATE TABLE IF NOT EXISTS people (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(40) NOT NULL, age INT)");
     if (!query.exec("CREATE TABLE IF NOT EXISTS people (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(40) NOT NULL, age INT)")) {
       handleDatabaseError("Create table", query.lastError());
    if (!query.exec()) {
       qDebug() << "Error creating table:" << query.lastError().text();
      return false;
     }
     }
   
   
     return true;
     qDebug() << "Table 'people' created or already exists";
  }
  }
   
   
155行目: 180行目:
  bool DatabaseManager::insertRecord(const QString& name, int age)
  bool DatabaseManager::insertRecord(const QString& name, int age)
  {
  {
    checkConnection();
     QSqlQuery query;
     QSqlQuery query;
     query.prepare("INSERT INTO people (name, age) VALUES (:name, :age)");
     query.prepare("INSERT INTO people (name, age) VALUES (:name, :age)");
161行目: 188行目:
   
   
     if (!query.exec()) {
     if (!query.exec()) {
       qDebug() << "Error inserting record:" << query.lastError().text();
       handleDatabaseError("Insert record", query.lastError());
      return false;
     }
     }
   
   
     return true;
     qDebug() << "Record inserted successfully";
  }
  }
   
   
171行目: 197行目:
  bool DatabaseManager::updateRecord(int id, const QString& name, int age)
  bool DatabaseManager::updateRecord(int id, const QString& name, int age)
  {
  {
    checkConnection();
     QSqlQuery query;
     QSqlQuery query;
     query.prepare("UPDATE people SET name = :name, age = :age WHERE id = :id");
     query.prepare("UPDATE people SET name = :name, age = :age WHERE id = :id");
178行目: 206行目:
   
   
     if (!query.exec()) {
     if (!query.exec()) {
       qDebug() << "Error updating record:" << query.lastError().text();
       handleDatabaseError("Update record", query.lastError());
      return false;
     }
     }
   
   
     return true;
     if (query.numRowsAffected() == 0) {
      throw DatabaseException(QString("No record found with id: %1").arg(id));
    }
    qDebug() << "Record updated successfully";
  }
  }
   
   
// レコードの削除
  bool DatabaseManager::deleteRecord(int id)
  bool DatabaseManager::deleteRecord(int id)
  {
  {
    checkConnection();
     QSqlQuery query;
     QSqlQuery query;
     query.prepare("DELETE FROM people WHERE id = :id");
     query.prepare("DELETE FROM people WHERE id = :id");
     query.bindValue(":id", id);
     query.bindValue(":id", id);
   
    if (!query.exec()) {
      handleDatabaseError("Delete record", query.lastError());
    }
   
   
     if (!query.exec()) {
     if (query.numRowsAffected() == 0) {
       qDebug() << "Error deleting record:" << query.lastError().text();
       throw DatabaseException(QString("No record found with id: %1").arg(id));
      return false;
     }
     }
   
   
     return true;
     qDebug() << "Record deleted successfully";
  }
  }
   
   
  // 全てのレコードを読み込む
  // 全てのレコードを読み込む
  void DatabaseManager::readAllRecords()
  QList<QMap<QString, QVariant>> DatabaseManager::readAllRecords()
  {
  {
    checkConnection();
     QSqlQuery query("SELECT * FROM people");
     QSqlQuery query("SELECT * FROM people");
    QList<QMap<QString, QVariant>> results;
   
    if (!query.exec()) {
      handleDatabaseError("Read all records", query.lastError());
    }
     while (query.next()) {
     while (query.next()) {
       int id = query.value(0).toInt();
       QMap<QString, QVariant> record;
       QString name = query.value(1).toString();
      record["id"] = query.value(0);
       int age = query.value(2).toInt();
       record["name"] = query.value(1);
       qDebug() << "ID:" << id << "Name:" << name << "Age:" << age;
       record["age"] = query.value(2);
       results.append(record);
     }
     }
    return results;
  }
  }
  </syntaxhighlight>
  </syntaxhighlight>
219行目: 267行目:
     DatabaseManager dbManager;
     DatabaseManager dbManager;
   
   
     if (dbManager.openConnection()) {
     try {
      // データーベースの接続
      dbManager.openConnection();
     
       // テーブルの作成
       // テーブルの作成
       dbManager.createTable();
       dbManager.createTable();
228行目: 279行目:
   
   
       // 全てのレコードを読み込む
       // 全てのレコードを読み込む
       dbManager.readAllRecords();
       QList<QMap<QString, QVariant>> records = dbManager.readAllRecords();
      for (const auto& record : records) {
          qDebug() << "ID:" << record["id"].toInt()
                    << "Name:" << record["name"].toString()
                    << "Age:" << record["age"].toInt();
        }
   
   
      // 既存のレコードの更新
        // 既存のレコードの更新
      dbManager.updateRecord(1, "John Doe Updated", 31);
        dbManager.updateRecord(1, "John Doe Updated", 31);
   
   
      // 任意のレコードの削除
        // 任意のレコードの削除
      dbManager.deleteRecord(2);
        dbManager.deleteRecord(2);
   
   
      // 全てのレコードを読み込む
        // 全てのレコードを読み込む
      dbManager.readAllRecords();
        records = dbManager.readAllRecords();
        for (const auto& record : records) {
       // データーベースを切断
          qDebug() << "ID:" << record["id"].toInt()
       dbManager.closeConnection();
                    << "Name:" << record["name"].toString()
                    << "Age:" << record["age"].toInt();
        }
    }
    catch (const DatabaseException &e) {
       // データベース関連のエラー
       qCritical() << "Database error: " << e.what();
    }
    catch (const std::exception &e) {
      // その他のエラー
      qCritical() << "Unexpected error: " << e.what();
     }
     }
   
   
「https://mochiuwiki.one/index.php/特別:携帯機器差分/10511」から取得

案内メニュー