#include <stdio.h>
#include <mysql.h>
#include <stdlib.h>
#include <string.h>

int main()
{
  MYSQL*      sql;
  MYSQL_STMT* stmt;
  MYSQL_BIND  bind, bind_result;

  int id, col, rows;
  unsigned long id_len, col_len;

  char query1[] = "create database if not exists mydb";
  char query2[] = "drop table if exists mydb.mytable;";
  char query3[] = "create table mydb.mytable(id int not null, col int not null)";
  char query4[] = "insert into mydb.mytable (id, col) values (1,100), (1,200),(2,300)";
  char query5[] = "select col from mydb.mytable where id = ?";

  char *server_options[] = {"test", "--defaults-file=my_embedded.cnf", NULL};
  int  num_elements = sizeof(server_options)/ sizeof(char *) - 1;

  printf("starting server...\n");
  if(mysql_library_init(num_elements, server_options, NULL))
  {
    puts("failed to initialize server"); 
    return 1;
  }

  printf("connect to server...\n");
  sql = mysql_init(NULL);

  if(!mysql_real_connect(sql, NULL , NULL , NULL , NULL, 0, NULL, 0))
    printf("failed to connect\n");

  if(mysql_query(sql, query1))
    printf("failed to create database:%s\n",  mysql_error(sql));

  if (mysql_query(sql, query2))
    printf("failed to use database:%s\n",  mysql_error(sql));

  if (mysql_query(sql, query3))
    printf("failed to create table:%s\n",  mysql_error(sql));

  if (mysql_query(sql, query4))
    printf("failed to insert record:%s\n",  mysql_error(sql));

  stmt = mysql_stmt_init(sql);
  if(!stmt)
    printf("failed to init stmt:%s\n",  mysql_error(sql));

  if (mysql_stmt_prepare(stmt, query5, strlen(query5)))
    printf("failed to prepare:%s\n",  mysql_stmt_error(stmt));

  memset(&bind, 0 , sizeof(bind));

  bind.buffer_type = MYSQL_TYPE_LONG;
  bind.is_unsigned = (my_bool)0;
  bind.is_null = 0;
  bind.buffer = (char*)&id;
  bind.buffer_length = 4;
  bind.length = &id_len;

  memset(&bind_result, 0 , sizeof(bind_result));

  bind_result.buffer_type = MYSQL_TYPE_LONG;
  bind_result.is_unsigned = (my_bool)0;
  bind_result.is_null = 0;
  bind_result.buffer = (char*)&col;
  bind_result.buffer_length = 4;
  bind_result.length = &col_len;

  if (mysql_stmt_bind_param(stmt, &bind))
    printf("failed to bind param:%s\n",  mysql_stmt_error(stmt));

  if (mysql_stmt_bind_result(stmt, &bind_result))
    printf("failed to bind param:%s\n",  mysql_stmt_error(stmt));

  id = 1;
  if (mysql_stmt_execute(stmt))
    printf("failed to execute stmt:%s\n",  mysql_stmt_error(stmt));

  if (mysql_stmt_store_result(stmt))
    printf("failed to store result:%s\n",  mysql_stmt_error(stmt));

  rows = mysql_stmt_num_rows(stmt);
  printf("result: %d rows\n", rows);
  while (rows-- && !mysql_stmt_fetch(stmt))
    printf("id = %d, col = %d, length = %d\n", id, col, col_len);

  mysql_stmt_free_result(stmt);

  id = 2;
  if (mysql_stmt_execute(stmt))
    printf("failed to execute stmt:%s\n",  mysql_stmt_error(stmt));

  if (mysql_stmt_store_result(stmt))
    printf("failed to store result:%s\n",  mysql_stmt_error(stmt));

  rows = mysql_stmt_num_rows(stmt);
  printf("result: %d rows\n", rows);
  while (rows-- && !mysql_stmt_fetch(stmt))
    printf("id = %d, col = %d, length = %d\n", id, col, col_len);

  mysql_stmt_free_result(stmt);

  printf("closing stmt...\n"); 
  mysql_stmt_close(stmt);

  printf("closing conneciton...\n"); 
  mysql_close(sql);

  printf("shutdown server...\n"); 
  mysql_library_end();

  return 0;
}