postgresql使用手記


項目要用到數據庫,本來打算用資料更多,名聲更好的mysql的。卸載了自帶的版本裝了MariaDB 10.0,然后發現沒有成熟的C++庫可用(只有一個提交不久的libmariadb++),於是想回滾到原來的mysql5.5,但是悲劇的事情發生了…回滾出問題了。用的系統是Linux Mint14,不管是purge還是remove,然后重裝MySQL的時候都會卡死…

於是我直接放棄了MySQL,用上了據說國內很少用,但是企業中用的不少的PostGreSQL。 安裝過程不說了,用源里面的資源就行,我現在的版本是9.2。

C++庫是libpqxx3-dev,官網有4.0.1的版本,我自己裝了一下,鏈接的時候有些問題1,推薦還是用源里面的版本。貌似必須裝到/usr/下,直接用sudo make install 裝到/usr/local下的話,下面的例子可能通不過…

PostGreSQLMySQL的管理方式差得挺遠,命令上也沒啥相似的(除了SQL語句)。常用的幾條命令包括:

createdb                                --直接在shell里面輸入,而不是連接到數據庫后
createuser
psql -d database_name -U username -p    --連接數據庫
\password                               --連接后,修改密碼
\l                                      --列出所有數據庫,也可以直接psql -l
\d table_name                           --描述表格,相當於MySQL中的describe
\?                                      --其他命令的幫助

容易看出這貨很有微軟風格…此外,這貨還有個GUI的管理程序,挺好用的,名字叫pgadmin,也可以從源里面裝。注意要使用這貨還要裝postgresql-contrib這個包,不然會提示沒有裝管理工具。

我粗略看了一下pqxx的指引文件,作者封裝的比較好了。比較有特色的是實現了數據庫的事務功能,也就是所謂的原子操作,有點類似C++中的異常安全。但是作者沒給出相關的例子,example里面只有簡單的過程式編程的例子,如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
#include <iostream>
#include <pqxx/pqxx>
using namespace std;
int main()
{
    try
    {
            pqxx::connection conn("dbname=test user=xiaoming");
            if(conn.is_open())
            {
                cout<<"Connect successful!"<<endl;
                cout<<conn.options()<<endl;
            }
            else
            {
                cout<<"something wrong ..oops"<<endl;
                return 1;
            }
            pqxx::work w(conn);
            pqxx::result r=w.exec("SELECT * FORM TEST");
            w.commit();

            for(auto iter=r.begin();iter!=r.end();++r)
            {
                for(auto seg=iter->begin();seg!=iter->end();++seg)
                    cout<<seg->c_str()<<'\t';
                    cout<<endl;
            }
        }
        catch(exception &e)
        {
            cout<<e.what()<<endl;
            return 1;
        }

        return 0;
}

g++的編譯選項:-lpq -lpqxx -std=c++11

別的都容易理解,注意pqxx::result是一個容器,重載了[]操作符,返回一個tuple類,這個tuple不是C++11標准庫里面那個,而是作者自己寫的。所以他的表現形式和std::tuple差別挺大的,倒是有點像std::map,可以直接通過重載的[]根據列名訪問表格的數據,當然用下標指定第幾列也是可以的。如果用迭代器訪問,最好使用C++11的語法,不然就typedef吧,超級長的類型名。返回的數據類型是pqxx::field。這個類里面有很多實用函數,如上面的c_str(),也可以用as<string>()來獲得。

上面這種過程式編程方法也是可行的,自己寫個類打個包就能搞了。不過作者給了一種更好的方案,也就是上面提到的事務,使用這種方式,能夠更安全簡介。我自己寫了一段示例代碼,作為測試程序:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
#include <iostream>
#include <exception>
#include <functional>
#include <pqxx/pqxx>
#include <pqxx/transaction>
#include <pqxx/transactor>

using namespace std;

class Trans:public pqxx::transactor<>{
public:
    Trans(){}
    Trans(const string query):
        query_(query){}
    void operator()(transaction<> &t){
        results_=t.exec(query_);
    }
    void on_commit(){
        cout<<"query successful!"<<endl;
        for(auto iter=results_.begin();iter!=results_.end();++iter){
            for(auto seg=iter->begin();seg!=iter->end();++seg){
                cout<<seg->as<string>()<<'\t';
            }
            cout<<endl;
        }
    }
    void on_doubt(){
        cout<<"doubt query"<<endl;
    }

    void on_abort(const string msg){
        cout<<"query failed: "
           <<msg<<endl;
    }

private:
    string query_;
    pqxx::result results_;
};

int main(){
    pqxx::connection conn("dbname=test user=terran");
    if(conn.is_open()){
        cout<<"Connect successful!"<<endl;
        cout<<conn.options()<<endl;
    }else{
        cout<<"something wrong ...oops"<<endl;
        return 1;
    }
    Trans t("SELECT * FROM test_table");
    conn.perform(t);

    return 0;
}

事務的大概用法如上所示,先繼承pqxx::transactor<>類(這是個模板,有默認參數),然后實現三個on_函數,把命令放在重載的函數調用操作符里面。調用方只需要簡單的.perform就可以了。如果執行成功,會調用on_commit,失敗會調用on_abort,提交了但是不能確定是不是成功(一般就是失去連接了),調用on_doubt

大概就是以上內容吧,pqxx庫的實現還是蠻復雜的,其他的還要細看。


  1. 我在編譯的時候會提示找不到PQxx的定義,然后編譯器提示找不到libpq-fe.h文件,推測是由於安裝到/usr/include/postgresql而不是/usr/include的原因。如果有人知道怎么解決,請留言告知,多謝。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM