#include <mio.h>
#include <mio-maria.h>
#include <stdio.h>
#include <string.h>

static void maria_on_disconnect (mio_dev_maria_t* dev)
{
}

static void maria_on_connect (mio_dev_maria_t* dev)
{
printf ("CONNEcTED...\n");
	if (mio_dev_maria_querywithbchars(dev, "SHOW STATUS", 11) <= -1)
	{
		mio_dev_maria_halt (dev);
	}
}

static void maria_on_query_started (mio_dev_maria_t* dev)
{
printf ("QUERY SENT...\n");
	if (mio_dev_maria_fetchrow(dev) <= -1)
	{
printf ("FETCH ROW FAILURE\n");
		mio_dev_maria_halt (dev);
	}
}

static void maria_on_row_fetched (mio_dev_maria_t* dev, void* row)
{
	if (!row) printf ("NO MORE ROW..\n");
	else
	{	
		printf ("GOT ROW\n");
		mio_dev_maria_fetchrow (dev);
	}
}

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

	mio_t* mio = MIO_NULL;
	mio_dev_maria_t* maria;
	mio_dev_maria_make_t mi;
	mio_dev_maria_connect_t ci;

	if (argc != 6)
	{
		fprintf (stderr, "Usage: %s ipaddr port username password dbname\n", argv[0]);
		return -1;
	}

	mio = mio_open(MIO_NULL, 0, MIO_NULL, 512, MIO_NULL);
	if (!mio)
	{
		printf ("Cannot open mio\n");
		goto oops;
	}

	memset (&ci, 0, MIO_SIZEOF(ci));
	ci.host = argv[1];
	ci.port = 3306; /* TODO: argv[2]; */
	ci.username = argv[3];
	ci.password = argv[4];
	ci.dbname = argv[5];

	memset (&mi, 0, MIO_SIZEOF(mi));
	/*mi.on_write = maria_on_write;
	mi.on_read = maria_on_read;*/
	mi.on_connect = maria_on_connect;
	mi.on_disconnect = maria_on_disconnect;
	mi.on_query_started = maria_on_query_started;
	mi.on_row_fetched = maria_on_row_fetched;

	maria = mio_dev_maria_make(mio, 0, &mi);
	if (!maria)
	{
		printf ("Cannot make a maria db client device\n");
		goto oops;
	}

	if (mio_dev_maria_connect(maria, &ci) <= -1)
	{
		printf ("Cannot connect to maria db server\n");
		goto oops;
	}

	mio_loop (mio);

oops:
	if (mio) mio_close (mio);
	return 0;
}