#!/usr/bin/env php

<?php

/**

* Licensed to the Apache Software Foundation (ASF) under one

* or more contributor license agreements. See the NOTICE file

* distributed with this work for additional information

* regarding copyright ownership. The ASF licenses this file

* to you under the Apache License, Version 2.0 (the

* "License"); you may not use this file except in compliance

* with the License. You may obtain a copy of the License at

*

* https://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS,

* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

* See the License for the specific language governing permissions and

* limitations under the License.

*/

require_once __DIR__ . '/../vendor/autoload.php';

use Apache\Avro\DataFile\AvroDataIO;

use Apache\Avro\DataFile\AvroDataIOReader;

use Apache\Avro\DataFile\AvroDataIOWriter;

use Apache\Avro\Datum\AvroIODatumReader;

use Apache\Avro\Datum\AvroIODatumWriter;

use Apache\Avro\IO\AvroStringIO;

use Apache\Avro\Schema\AvroSchema;

// Write and read a data file

$writers_schema_json = <<<_JSON

{"name":"member",

"type":"record",

"fields":[{"name":"member_id", "type":"int"},

{"name":"member_name", "type":"string"}]}

_JSON;

$jose = array('member_id' => 1392, 'member_name' => 'Jose');

$maria = array('member_id' => 1642, 'member_name' => 'Maria');

$data = array($jose, $maria);

$file_name = 'data.avr';

// Open $file_name for writing, using the given writer's schema

$data_writer = AvroDataIO::openFile($file_name, 'w', $writers_schema_json);

// Write each datum to the file

foreach ($data as $datum)

$data_writer->append($datum);

// Tidy up

$data_writer->close();

// Open $file_name (by default for reading) using the writer's schema

// included in the file

$data_reader = AvroDataIO::openFile($file_name);

echo "from file:\n";

// Read each datum

foreach ($data_reader->data() as $datum)

echo var_export($datum, true) . "\n";

$data_reader->close();

// Create a data string

// Create a string io object.

$io = new AvroStringIO();

// Create a datum writer object

$writers_schema = AvroSchema::parse($writers_schema_json);

$writer = new AvroIODatumWriter($writers_schema);

$data_writer = new AvroDataIOWriter($io, $writer, $writers_schema);

foreach ($data as $datum)

$data_writer->append($datum);

$data_writer->close();

$binary_string = $io->string();

// Load the string data string

$read_io = new AvroStringIO($binary_string);

$data_reader = new AvroDataIOReader($read_io, new AvroIODatumReader());

echo "from binary string:\n";

foreach ($data_reader->data() as $datum)

echo var_export($datum, true) . "\n";

/** Output

from file:

array (

'member_id' => 1392,

'member_name' => 'Jose',

)

array (

'member_id' => 1642,

'member_name' => 'Maria',

)

from binary string:

array (

'member_id' => 1392,

'member_name' => 'Jose',

)

array (

'member_id' => 1642,

'member_name' => 'Maria',

)

*/