3

我试图将用于连接本地 PostgreSQL 服务器的代码从我的“main.cpp”文件外包到一个名为“database.cpp”的单独类中。

当我在“main.cpp”中有代码时，连接工作得很好：

主文件

QSqlDatabase db = QSqlDatabase::addDatabase("QPSQL");
QSqlQuery query(db);

qint32 declareConnection()
{
    db.setHostName("127.0.0.1");
    db.setPort(5432);
    db.setDatabaseName("postgres");
    db.setUserName("postgres");
    db.setPassword("password");

    return 0;
}

qint32 createUser(QString username, QString password)
{
    if (db.open())
    {
        db.transaction();

        query.prepare("INSERT INTO users (name, password) VALUES (?, ?);");
        query.bindValue(0, username);
        query.bindValue(1, toMD5(password));

        query.exec();
        query.finish();

        db.commit();
        db.close();
    }

    return 0;
}

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    qDebug() << "Declare Database: " << declareConnection();
    qDebug() << "Create User: " << createUser("Testuser", "Testpassword");

    return a.exec();
}

但是在我将函数放入“database.cpp”之后，每次我尝试执行它时，prepare.query() 都会失败。这是我当前的代码：

主文件

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    Database postgre;

    qDebug() << "Declare Database: " << postgre.declareConnection();
    qDebug() << "Create User: " << postgre.createUser("Testuser", "Testpassword");

    return a.exec();
}

数据库.h

class Database : public QObject
{
Q_OBJECT
public:
explicit Database(QObject *parent = 0);

qint32 declareConnection();
qint32 createUser(QString username, QString password);

QSqlDatabase db();
};

数据库.cpp

QSqlDatabase Database::db()
{
    return QSqlDatabase::database();
}

qint32 Database::declareConnection()
{
    QSqlDatabase db = QSqlDatabase::addDatabase("QPSQL");

    db.setHostName("127.0.0.1");
    db.setPort(5432);
    db.setDatabaseName("postgres");
    db.setUserName("postgres");
    db.setPassword("password");

    return 0;
}

qint32 Database::createUser(QString username, QString password)
{
    if (db().open())
    {
        db().transaction();

        QSqlQuery query(db());
        query.prepare("INSERT INTO users (name, password) VALUES (?, ?);");
        query.bindValue(0, username);
        query.bindValue(1, toMD5(password));

        query.exec();
        query.finish();

        db().commit();
        db().close();
    }

    return 0;
}

数据库的声明似乎工作得很好，但是当涉及到“createUser()”函数时，“query.prepare()”命令总是存在这个问题。

数据库已打开，因此可以正常工作。当我签入调试时，事务
也处于打开状态。准备是错误
的。 query.exec() 说：第 1 行末尾的语法错误： EXECUTE ^。 QPSQL：无法创建查询。 警告：没有未结交易。（但是是开放的？？？）


4

1 回答 1

1

问题就在这里

无效数据库::declareConnection() { QSqlDatabase db = QSqlDatabase::addDatabase("QPSQL");

您在堆栈上声明了局部变量。db决定是：

class Database : public QObject
{
   ...
   QSqlDatabase & db() { return m_db; }
private:
   QSqlDatabase m_db;
};

void Database::declareConnection()
{
    m_db = QSqlDatabase::addDatabase("QPSQL");
...
}
于 2013-01-21T14:39:06.770 回答