--TEST--
	mysqlx sql simple
--SKIPIF--
--FILE--
<?php
	require("connect.inc");

	$session = mysql_xdevapi\getSession($connection_uri);
	$session->sql("create database $db")->execute();
	$session->sql("create table $db.$test_table_name(name text, age tinyint, job text)")->execute();

	$schema = $session->getSchema($db);
	$table = $schema->getTable($test_table_name);

	fill_db_table();

	$sql = $session->sql("select * from $db.$test_table_name");
	expect_false($sql->hasMoreResults());
	expect_false($sql->getResult());
	expect_false($sql->getNextResult());
	$sql = $sql->execute();
	expect_true($sql->hasData());
	expect_eq($sql->getAffectedItemsCount(), 0);
	expect_eq($sql->getWarningsCount(), 0);
	expect_eq($sql->getColumnsCount(), 3);
	$col_name = $sql->getColumnNames();
	expect_eq($col_name[0],"name");
	expect_eq($col_name[1],"age");
	expect_eq($col_name[2],"job");

	$res = $sql->fetchAll();
	expect_eq(count($res), 12);

	$sql = $session->sql("insert into $db.$test_table_name values ('Alessio',56,'driver'),('Mattia',33,'nurse'),('Lucrezia',67,'saleswoman')")->execute();
	expect_eq($sql->getLastInsertId(),0);
	expect_eq($sql->getGeneratedIds(),[]);
	expect_false($sql->hasData());
	expect_eq($sql->getAffectedItemsCount(), 3);
	expect_eq($sql->getWarningsCount(), 0);
	expect_eq($sql->getColumnsCount(), 0);

	$sql = $session->sql("select * from $db.$test_table_name where age < ? order by age desc, name asc limit ?")->bind(14)->bind(2)->execute();
	expect_false($sql->nextResult());
	expect_true($sql->hasData());
	expect_eq($sql->getAffectedItemsCount(), 0);
	expect_eq($sql->getWarningsCount(), 0);
	expect_eq($sql->getColumnsCount(), 3);
	$col_name = $sql->getColumnNames();
	expect_eq($col_name[0],"name");
	expect_eq($col_name[1],"age");
	expect_eq($col_name[2],"job");
	$columns = $sql->getColumns();
	expect_eq($columns[0]->getColumnName(),"name");
	expect_eq($columns[0]->getTableName(),$test_table_name);
	expect_eq($columns[1]->getColumnName(),"age");
	expect_eq($columns[1]->getTableName(),$test_table_name);
	expect_eq($columns[2]->getColumnName(),"job");
	expect_eq($columns[2]->getTableName(),$test_table_name);

	$res = $sql->fetchOne();
	expect_eq($res['name'],'Cassidy');
	expect_eq($res['age'], 13);
	expect_eq($res['job'], 'student');
	$res = $sql->fetchOne();
	expect_eq($res['name'],'Polly');
	expect_eq($res['age'], 12);
	expect_eq($res['job'], 'tailor');

	try {
		$session->sql("select wrong from $db.$test_table_name")->execute();
		test_step_failed();
	}catch(Exception $e) {
		expect_eq($e->getMessage(),
				"[HY000] Couldn't fetch data");
		expect_eq($e->getCode(), 10000);
	}

	try {
		//Not tiny!
		$sql = $session->sql("insert into $db.$test_table_name values ('Carlos',9999,'fitter')")->execute();
		test_step_failed();
	}catch(Exception $e) {
		expect_eq($e->getMessage(),
				"[HY000] Couldn't fetch data");
		expect_eq($e->getCode(), 10000);
	}

	$sql = $session->sql("select age, age/0 as x from $db.$test_table_name limit 2")->execute();
	expect_true($sql->hasData());
	expect_eq($sql->getAffectedItemsCount(), 0);
	expect_eq($sql->getWarningsCount(), 2);
	$warn = $sql->getWarnings();
	for( $i = 0 ; $i < 2; $i++ ) {
		//expect_eq($warn[0]->message,'');
		expect_eq($warn[0]->level,2);
		expect_eq($warn[0]->code,1365);
	}
	expect_eq($sql->getColumnsCount(), 2);

	verify_expectations();
	print "done!\n";
?>
--CLEAN--
<?php
	require("connect.inc");
	clean_test_db();
?>
--EXPECTF--
done!%A