#include <soci/soci.h>
#include <iostream>
#include <istream>
#include <ostream>
#include <string>
#include <exception>

using namespace soci;
using namespace std;

/*
 * mysql> desc test;
 * +-------+-------------+------+-----+---------+----------------+
 * | Field | Type        | Null | Key | Default | Extra          |
 * +-------+-------------+------+-----+---------+----------------+
 * | id    | int(50)     | NO   | PRI | NULL    | auto_increment |
 * | name  | varchar(50) | YES  |     | NULL    |                |
 * +-------+-------------+------+-----+---------+----------------+
 */
struct Person
{
    int id;
    std::string name;
};

namespace soci
{
template<> struct type_conversion<Person>
{
    typedef values base_type;
    static void from_base(values const & v, indicator /* ind */, Person & p)
    {
        p.id = v.get<int>("id");
        p.name = v.get<std::string>("name");
    }
    static void to_base(const Person & p, values & v, indicator & ind)
    {
	cout << "setting id to " << p.id << " and name to '" << p.name << "'" << endl;
        v.set("id", p.id);
        v.set("name", p.name);
        ind = i_ok;
    }
};
}

void purge(session &sql)
{
	int count;
        sql << "select count(*) from test", into(count);
	if (count > 0) {
        	cout << "We have " << count << " entries in test: deleting.";
		sql << "DELETE FROM test";
	} else {
		cout << "No entry in test." << endl;
	}
}

void insert(session &sql)
{
	purge(sql);
	Person p;
	p.id = -1; p.name = "default";
	statement st = (sql.prepare << "insert into test(id, name) values(:id, :name)", use(p));
	sql.begin();
	for (int i=1; i <= 10000; i++) {
		p.id = i;
		ostringstream sname;
		sname << "NameNumber" << i;
		p.name = sname.str();
		cout << "Trying to insert id=" << p.id << " and name=" << p.name << endl;
		st.execute(true);
	}
	sql.commit();
}

void select(session &sql)
{
	Person p;
	statement st = (sql.prepare << "select id, name from test", into(p));
	st.execute();
	while (st.fetch()) {
		cout << "Id=" << p.id << " Name=" << p.name << endl;
	}
}

int main()
{
    try
    {
        session sql("mysql", "dbname=test user=root password=''");

	insert(sql);
	select(sql);
    }
    catch (exception const &e)
    {
        cerr << "Error: " << e.what() << '\n';
    }
}