@:buildXml('<include name=\"${haxelib:hxCassandra}/Build.xml\" />')
class Main {
    public static function main() {

        var cluster = Cassandra.cluster_new();
        var session = Cassandra.session_new();

        Cassandra.cluster_set_contact_points(cluster, "127.0.0.1");

        var connect_future = Cassandra.session_connect(session, cluster);
        var error = Cassandra.future_error_code(connect_future);
        if (error != CassError.CASS_OK) {
            var message:ConstCharStar = "";
            var message_length:SizeT = 0;
            Cassandra.future_error_message(connect_future, RawPointer.addressOf(message), RawPointer.addressOf(message_length));
            trace(message);
            return;
        }

        Cassandra.future_free(connect_future);
        trace("connected");

        //var statement = Cassandra.statement_new("SELECT * FROM mhsnosearch.aliases", 0);
        var statement = Cassandra.statement_new("SELECT * FROM mhsnosearch.services", 0);
        //var statement = Cassandra.statement_new("SELECT * FROM mhsnosearch.service_routes", 0);
        var statement_future = Cassandra.session_execute(session, statement);
        var error = Cassandra.future_error_code(statement_future);
        if (error != CassError.CASS_OK) {
            var message:ConstCharStar = "";
            var message_length:SizeT = 0;
            Cassandra.future_error_message(statement_future, RawPointer.addressOf(message), RawPointer.addressOf(message_length));
            trace(message);
            return;
        }

        var result = Cassandra.future_get_result(statement_future);
        if (result == null) {
            var message:ConstCharStar = "";
            var message_length:SizeT = 0;
            Cassandra.future_error_message(statement_future, RawPointer.addressOf(message), RawPointer.addressOf(message_length));
            trace(message);
            return;
        }

        Cassandra.future_free(statement_future);
        var n = 0;
        var it = Cassandra.iterator_from_result(result);
        while (Cassandra.iterator_next(it)) {
            var row = Cassandra.iterator_get_row(it);

            Sys.print("" + n + ". ");

            for (i in 0...Cassandra.result_column_count(result)) {
                var column_name:ConstCharStar = "";
                var column_name_length:SizeT = 0;
                Cassandra.result_column_name(result, i, RawPointer.addressOf(column_name), RawPointer.addressOf(column_name_length));

                var value:ConstCharStar = "";
                var value_length:SizeT = 0;
                Cassandra.value_get_string(Cassandra.row_get_column_by_name(row, column_name), RawPointer.addressOf(value), RawPointer.addressOf(value_length));

                var v:String = value.toString().substr(0, value_length);

                Sys.print("" + column_name.toString().substr(0, column_name_length) + ": " + v + ", ");
            }
            Sys.print("\n");
            n++;
        }
        trace("columns: " + Cassandra.result_column_count(result));
        trace("rows: " + Cassandra.result_row_count(result));

        Cassandra.result_free(result);
        Cassandra.session_free(session);
        Cassandra.cluster_free(cluster);
    }

}