/*

CREATE DATABASE test;

CREATE USER 'test'@'localhost' IDENTIFIED BY 'test';

GRANT ALL PRIVILEGES ON test.* TO 'test'@'localhost' IDENTIFIED BY 'test';

flush PRIVILEGES;

*/

import java.sql.*;

import static org.junit.Assert.assertEquals;

public class Test {

    @org.junit.Test

    public void test() throws Exception {

        Class.forName("org.mariadb.jdbc.Driver");

        String createStmt = "CREATE TABLE table1(" +

                "`id` int(11) NOT NULL AUTO_INCREMENT, value1 int default NULL, value2 smallint(6) default null, " +

                "PRIMARY KEY (`id`) ) ENGINE=MyISAM AUTO_INCREMENT=56840 DEFAULT CHARSET=utf8";

        try (Connection connection = DriverManager.getConnection("jdbc:mariadb://localhost/test", "test", "test")) {

            try {

                connection.prepareStatement(createStmt).execute();

                PreparedStatement prepareStatement = connection.prepareStatement("INSERT INTO table1(value1, value2) VALUES (?,?)", Statement.RETURN_GENERATED_KEYS);

                prepareStatement.setObject(1, -1, java.sql.Types.INTEGER);

                prepareStatement.setObject(2, -1, java.sql.Types.INTEGER);

                prepareStatement.execute();

                ResultSet rs = prepareStatement.getGeneratedKeys();

//                    if (rs.next()) {

//                        System.out.println(rs.getLong(1));

//                    }

                try (PreparedStatement statement = connection.prepareStatement("SELECT value1, value2 from table1")) {

                    statement.executeQuery();

                    ResultSet resultSet = statement.getResultSet();

                    while (resultSet.next()) {

                        assertEquals(new Integer(-1), new Integer(resultSet.getInt("value1")));

                        assertEquals(new Integer(-1), new Integer(resultSet.getShort("value2")));

                        assertEquals(new Integer(-1), new Integer(resultSet.getInt("value2")));

                    }

                }

                try (PreparedStatement statement = connection.prepareStatement("SELECT value1, value2 from table1 where value1 = ?")) {

                    statement.setInt(1, -1);

                    statement.executeQuery();

                    ResultSet resultSet = statement.getResultSet();

                    while (resultSet.next()) {

                        assertEquals(new Integer(-1), new Integer(resultSet.getInt("value1")));

                        assertEquals(new Integer(-1), new Integer(resultSet.getShort("value2")));

                        assertEquals(new Integer(-1), new Integer(resultSet.getInt("value2")));

                    }

                }

            } finally {

                connection.prepareStatement("drop table table1").execute();

            }

        }

    }

}