首页 > 代码库 > Mysql++学习(三)------举个栗子

Mysql++学习(三)------举个栗子

下面例子显示了如何建立利用Sql++建立一个连接,执行查询操作,返回一个结果集,并且打印.

 1 #include <iostream> 2 #include <mysql++.h> 3 #include <errno.h> 4 #include <stdlib.h> 5 #include <stdio.h> 6  7 using namespace std; 8  9 int main()10 {11     mysqlpp::Connection conn(false);12     //connect to the database13     if(conn.connect("mysql_cpp_data", "127.0.0.1", "comoon", ""))14     {15         //execute a query16         mysqlpp::Query query = conn.query("select * from stock");17         //get query result in a storeResult18         mysqlpp::StoreQueryResult res = query.store();19         if(res)20         {21             for(size_t i = 0; i < res.num_rows(); i++)22             {23                 cout << setw(20) << res[i]["item"] <<24                         setw(10) << res[i]["num"] <<25                         setw(10) << res[i]["weight"] <<26                         setw(10) << res[i]["price"] <<27                         setw(10) << res[i]["sdate"] <<28                         endl;29             }30         }31         else32         {33             perror("Failed to get data!");34             exit(EXIT_FAILURE);35         }36     }37     else38     {39         perror("Connect Failed");40         exit(EXIT_FAILURE);41     }42     return 0;43 }

 

异常

默认情况下,MySql++使用异常来通知错误,通过给connection的构建函数传递参数,来确定是否要开启异常处理,前面例子中使用false来关闭了异常,在一个正常程序中建议开启异常处理。

所有MySql++的常规异常,都继承自类Exception.而该类继承自标准C++的std::exception类.所以,仅仅通过捕获std::exception,就可以捕获和处理一切异常。不过,还是建议对于具体的异常采用捕获代码块。

 当异常处理被关闭的时候,MySql++通过返回错误代码,或者尝试失败的对象,或设置对象的错误标识来通知错误。继承自OptionalExcetions接口的对象允许你关闭异常,当一个OptionalExcetions衍生类创建了也继承自该接口的对象时,它也会传递异常标识。因为一切都源于connection对象,所以,在开始的时候关闭connection上的异常就会关闭所有OptionalExcetions。

也可以在一个代码块中关闭异常处理,你可以在代码开始地方创建一个NoExceptions对象,来防止代码块抛出异常。当它被创建之后,它会记录下传递过来的异常标识,在代码执行结束后,它将恢复异常标识到之前的状态。

mysqlpp::Connection con; // default ctor, so exceptions enabled{  mysqlpp::NoExceptions ne(con);  if (!con.select_db("a_db_that_might_not_exist_yet")) {    // Our DB doesn’t exist yet, so create and select it here; no need    // to push handling of this case way off in an exception handler.  }}

查询操作

MySql++支持三种查询: Query::execute()Query::store()和 Query::use()

execute()用于不返回数据的查询.例如执行CREATE INDEX,你并没有从服务器获取数据,程序将返回一个SimpleResult对象,以及一个标识执行成功与否的标识,该对象还包含命令执行所影响的行数,如果只要成功与否的标识,可以使用Query::exec(),其返回结果为bool.

如果你的查询需要从服务器拉数据,那么可以简单使用store().它将返回一个StoreQueryResult对象,该对象包含整个结果集,这将非常简单,因为StoreQueryResult 继承自std::vector<mysqlpp::Row>,它包含STL的各种操作.

如果你想将返回的结果集存在一个非vector的标准容器中,你可以使用Query::storein().

store*()查询可能很方便,但是,将整个结果集全部存储在内存中,代价可能会很大.事实上,MySql数据库服务器将数据压缩存储在硬盘上,但是返回给客户端的是文本形式.对于很大的返回结果集,最好使用use()查询.它返回一个UseQueryResult.该对象类似StoreQueryResult,但是不提供随机访问的特性.use查询会让服务器一次返回结果集的一行,进分行处理.

 if (mysqlpp::UseQueryResult res = query.use()) {            // Display header            cout.setf(ios::left);            cout << setw(31) << "Item" <<                    setw(10) << "Num" <<                    setw(10) << "Weight" <<                    setw(10) << "Price" <<                    "Date" << endl << endl;            // Get each row in result set, and print its contents            while (mysqlpp::Row row = res.fetch_row()) {                cout << setw(30) << row["item"] <<   <<                        setw(9) << row["num"] <<   <<                        setw(9) << row["weight"] <<   <<                        setw(9) << row["price"] <<   <<                        setw(9) << row["sdate"] <<                        endl;            }

条件结果行处理

有时候,你需要从服务器拉一些并不需要的数据,然后在内存中过滤.使用Query::store_if().

 

// Define a functor for testing primality.struct is_prime{    bool operator()(const stock& s)    {        if ((s.num == 2) || (s.num == 3)) {            return true;    // 2 and 3 are trivial cases        }        else if ((s.num < 2) || ((s.num % 2) == 0)) {            return false;   // can‘t be prime if < 2 or even        }        else {            // The only possibility left is that it‘s divisible by an            // odd number that‘s less than or equal to its square root.            for (int i = 3; i <= sqrt(double(s.num)); i += 2) {                if ((s.num % i) == 0) {                    return false;                }            }            return true;        }    }};......// Collect the stock items with prime quantitiesstd::vector<stock> results;mysqlpp::Query query = con.query();query.store_if(results, stock(), is_prime());

为结果集中每一行执行代码

SQL不只是一个数据库查询语言.现代的数据库引擎可以在服务器端做一些数据的运算,但是这并不是最好的选择.如果你需要混合代码和查询,MySQL++提供了 Query::for_each()机制.

// Define a functor to collect statistics about the stock tableclass gather_stock_stats{public:    gather_stock_stats() :    items_(0),    weight_(0),    cost_(0)    {    }    void operator()(const stock& s)    {        items_  += s.num;        weight_ += (s.num * s.weight);        cost_   += (s.num * s.price.data);    }    private:    mysqlpp::sql_bigint items_;    mysqlpp::sql_double weight_, cost_;    friend std::ostream& operator<<(std::ostream& os,            const gather_stock_stats& ss);};// Dump the contents of gather_stock_stats to a stream in human-readable// form.std::ostream&operator<<(std::ostream& os, const gather_stock_stats& ss){    os << ss.items_ << " items " <<            "weighing " << ss.weight_ << " stone and " <<            "costing " << ss.cost_ << " cowrie shells";    return os;} // Gather and display the stats for the entire stock tablemysqlpp::Query query = con.query();std::cout << "There are " << query.for_each(stock(),gather_stock_stats()) << . << std::endl;

连接选项

MySQL有大量的选项来控制你连接数据库的方式,以及连接的行为.

打开多重查询选项,并且建立连接

Connection con;con.set_option(new MultiStatementsOption(true));// Connect to the databaseif (!con.connect(mysqlpp::examples::db_name, cmdline.server(),  cmdline.user(), cmdline.pass())) {  return 1;}

执行多重查询

// Set up query with multiple queries.Query query = con.query();query << "DROP TABLE IF EXISTS test_table; " <<    "CREATE TABLE test_table(id INT); " <<    "INSERT INTO test_table VALUE S(10); " <<    "UPDATE test_table SET id=20 WHERE  id=10; " <<     "SELECT * FROM test_table; " <<     "DROP TABLE test_table"; cout << "Multi-query: " << endl << query << endl;

连接超时处理

MySQL连接在长时间闲置后会被MySQL关闭,默认是8小时.

一种处理连接超时的方式,是配置MySQL,重新设置其连接超时时间.

第二种方式可以采用ReconnectOption,在MySQL连接断开后会进行自动重连

第三种方式是使用Connection::ping()轮询检测连接是否关闭,如果关闭,就重新连接

Mysql++学习(三)------举个栗子