Follow us on Twitter @arangodbphp to receive updates on the PHP driver
This PHP client allows REST-based access to documents on the server. The DocumentHandler class should be used for these purposes. There is an example for REST-based documents access in the file examples/document.php.
Furthermore, the PHP client also allows to issue more AQL complex queries using the Statement class. There is an example for this kind of statements in the file examples/select.php.
To use the PHP client, you must include the file autoloader.php from the main directory. The autoloader will care about loading additionally required classes on the fly. The autoloader can be nested with other autoloaders.
The ArangoDB PHP client is an API that allows you to send and retrieve documents from ArangoDB from out of your PHP application. The client library itself is written in PHP and has no further dependencies but just plain PHP 5.4 (or higher).
The client library provides document and collection classes you can use to work with documents and collections in an OO fashion. When exchanging document data with the server, the library internally will use the HTTP REST interface of ArangoDB. The library user does not have to care about this fact as all the details of the REST interface are abstracted by the client library.
-
ArangoDB database server version 3.0 or higher. Detailed info here
-
PHP version 5.4 or higher (Travis-tested with PHP 5.4, 5.5, 5.6, 7 and hhvm)
To get started you need PHP 5.4 or higher plus an ArangoDB server running on any host that you can access.
There are two alternative ways to get the ArangoDB PHP client:
- Using packagist/composer
- Cloning the git repository
When using packagist, the procedure is as follows:
Get the composer.phar file from getcomposer.org:
curl -s http://getcomposer.org/installer | php
This will put the composer.phar file into the current directory. Next, create a new directory for your project, e.g. arangophp, and move into it:
mkdir arangophp && cd arangophp
Then, use composer's init command to define the initial dependencies for your project:
php ../composer.phar init
This will fire up composer's interactive config generator. It will ask you several questions, and the below example shows how you can answer them. Most questions have reasonable default settings and you can should use the defaults whenever you're unsure. When asked for a package name, type ## triagens/Arango. This is the package name for the ArangoDB PHP client. When being asked for a package number (package ##), you can either use dev-master (latest version) or one of the designated tagged versions.
Welcome to the Composer config generator
This command will guide you through creating your composer.json config.
Package name (/) [jsteemann/arangophp]:
Description []: An example application using ArangoDB PHP client
Author [jsteemann]:
Define your dependencies.
Would you like to define your dependencies interactively [yes]? yes
Search for a package []: triagens/Arango
Found 3 packages matching triagens/Arango
[0] triagens/ArangoDb dev-master
[1] triagens/ArangoDb V0.1.1
[2] triagens/ArangoDb V0.0.1
Enter package ## to add, or a couple if it is not listed []: 0
Search for a package []:
{
"name": "jsteemann/arangophp",
"description": "An example application using ArangoDB PHP client",
"require": {
"triagens/arangodb": "dev-master"
},
"authors": [
{
"name": "jsteemann",
"email": "[email protected]"
}
]
}
Do you confirm generation [yes]? yes
Would you like the vendor directory added to your .gitignore [yes]?
The above has created a file composer.json in your current directory, which contains information about your project plus the project dependencies. The ArangoDB PHP client is the only dependency for now, and it can be installed by running the following command:
php ../composer.phar update
Updating dependencies
- Package triagens/arangodb (dev-master)
Cloning e4e9107aec3d1e0c914e40436f77fed0e5df2485
Writing lock file
Generating autoload files
Running this command has created a subdirectory vendor in the current directory. The vendor directory contains a subdirectory triagens that contains the ArangoDB PHP client library files. The vendor directory also contains a subdirectory .composer that contains auto-generated autoloader files for all dependencies you defined in your composer.json file (the file auto-generated by running the previous init command).
You need to include the generated autoloader file in your project when using the ArangoDB PHP classes. You can do so by adding the following line to any PHP file that will use them:
require 'vendor/.composer/autoload.php';When preferring this alternative, you need to have a git client installed. To clone the ArangoDB PHP client repository from github, execute the following command in your project directory:
git clone "https://github.com/arangodb/arangodb-php.git"
This will create a subdirectory arangodb-php in your current directory. It contains all the files of the client library. It also includes a dedicated autoloader that you can use for autoloading the client libraries class files. To invoke this autoloader, add the following line to your PHP files that will use the library:
require 'arangodb-php/autoload.php';The ArangoDB PHP client's autoloader will only care about its own class files and will not handle any other files. That means it is fully nestable with other autoloaders.
If you do not wish to include autoload.php to load and setup the autoloader, you can invoke the autoloader directly:
require 'arangodb-php/lib/triagens/ArangoDb/autoloader.php';
\triagens\ArangoDb\Autoloader::init();In order to use ArangoDB, you need to specify the connection options. We do so by creating a PHP array $connectionOptions. Put this code into a file named test.php in your current directory:
// use the following line when using packagist/composer
// require dirname(__FILE__) . DIRECTORY_SEPARATOR . 'vendor' . DIRECTORY_SEPARATOR . '.composer' . DIRECTORY_SEPARATOR . 'autoload.php';
// use the following line when using git
require dirname(__FILE__) . DIRECTORY_SEPARATOR . 'arangodb-php' . DIRECTORY_SEPARATOR . 'autoload.php';
// set up some aliases for less typing later
use triagens\ArangoDb\Collection as ArangoCollection;
use triagens\ArangoDb\CollectionHandler as ArangoCollectionHandler;
use triagens\ArangoDb\Connection as ArangoConnection;
use triagens\ArangoDb\ConnectionOptions as ArangoConnectionOptions;
use triagens\ArangoDb\DocumentHandler as ArangoDocumentHandler;
use triagens\ArangoDb\Document as ArangoDocument;
use triagens\ArangoDb\Export as ArangoExport;
use triagens\ArangoDb\Statement as ArangoStatement;
use triagens\ArangoDb\Exception as ArangoException;
use triagens\ArangoDb\ConnectException as ArangoConnectException;
use triagens\ArangoDb\ClientException as ArangoClientException;
use triagens\ArangoDb\ServerException as ArangoServerException;
use triagens\ArangoDb\UpdatePolicy as ArangoUpdatePolicy;
// set up some basic connection options
$connectionOptions = array(
// database name
ArangoConnectionOptions::OPTION_DATABASE => '_system',
// server endpoint to connect to
ArangoConnectionOptions::OPTION_ENDPOINT => 'tcp://127.0.0.1:8529',
// authorization type to use (currently supported: 'Basic')
ArangoConnectionOptions::OPTION_AUTH_TYPE => 'Basic',
// user for basic authorization
ArangoConnectionOptions::OPTION_AUTH_USER => 'root',
// password for basic authorization
ArangoConnectionOptions::OPTION_AUTH_PASSWD => '',
// connection persistence on server. can use either 'Close' (one-time connections) or 'Keep-Alive' (re-used connections)
ArangoConnectionOptions::OPTION_CONNECTION => 'Keep-Alive',
// connect timeout in seconds
ArangoConnectionOptions::OPTION_TIMEOUT => 3,
// whether or not to reconnect when a keep-alive connection has timed out on server
ArangoConnectionOptions::OPTION_RECONNECT => true,
// optionally create new collections when inserting documents
ArangoConnectionOptions::OPTION_CREATE => true,
// optionally create new collections when inserting documents
ArangoConnectionOptions::OPTION_UPDATE_POLICY => ArangoUpdatePolicy::LAST,
);
$connection = new ArangoConnection($connectionOptions);This will make the client connect to ArangoDB
- running on localhost (OPTION_HOST)
- on the default port 8529 (OPTION_PORT)
- with a connection timeout of 3 seconds (OPTION_TIMEOUT)
When creating new documents in a collection that does not yet exist, you have the following choices:
- auto-generate a new collection: if you prefer that, set OPTION_CREATE to true
- fail with an error: if you prefer this behavior, set OPTION_CREATE to false
When updating a document that was previously/concurrently updated by another user, you can select between the following behaviors:
- last update wins: if you prefer this, set OPTION_UPDATE_POLICY to last
- fail with a conflict error: if you prefer that, set OPTION_UPDATE_POLICY to conflict
This is just to show how a collection is created.
For these examples it is not needed to create a collection prior to inserting a document, as we set ArangoConnectionOptions::OPTION_CREATE to true.
So, after we get the settings, we can start with creating a collection. We will create a collection named "users".
The below code will first set up the collection locally in a variable name $user, and then push it to the server and return the collection id created by the server:
$collectionHandler = new ArangoCollectionHandler($connection);
// create a new document
$userCollection = new ArangoCollection();
$userCollection->setName('users');
$id = $collectionHandler->add($userCollection);
// print the collection id created by the server
var_dump($id);After we created the collection, we can start with creating an initial document. We will create a user document in a collection named "users". This collection does not need to exist yet. The first document we'll insert in this collection will create the collection on the fly. This is because we have set OPTION_CREATE to true in $connectionOptions.
The below code will first set up the document locally in a variable name $user, and then push it to the server and return the document id created by the server:
$handler = new ArangoDocumentHandler($connection);
// create a new document
$user = new ArangoDocument();
// use set method to set document properties
$user->set("name", "John");
$user->set("age", 25);
// use magic methods to set document properties
$user->likes = array('fishing', 'hiking', 'swimming');
// send the document to the server
$id = $handler->add('users', $user);
// print the document id created by the server
var_dump($id);Document properties can be set by using the set() method, or by directly manipulating the document properties.
As you can see, sending a document to the server is achieved by calling the add() method on the client library's DocumentHandler class. It needs the collection name ("users" in this case") plus the document object to be added. add() will return the document id as created by the server. The id is a numeric value that might or might not fit in a PHP integer.
The above code will work but it does not check for any errors. To make it work in the face of errors, we'll wrap it into some basic exception handlers
try {
$connection = new ArangoConnection($connectionOptions);
$handler = new ArangoDocumentHandler($connection);
// create a new document
$user = new ArangoDocument();
// use set method to set document properties
$user->set("name", "John");
$user->set("age", 25);
// use magic methods to set document properties
$user->likes = array('fishing', 'hiking', 'swimming');
// send the document to the server
$id = $handler->add('users', $user);
// print the document id created by the server
var_dump($id);
} catch (ArangoConnectException $e) {
print 'Connection error: ' . $e->getMessage() . PHP_EOL;
} catch (ArangoClientException $e) {
print 'Client error: ' . $e->getMessage() . PHP_EOL;
} catch (ArangoServerException $e) {
print 'Server error: ' . $e->getServerCode() . ':' . $e->getServerMessage() . ' ' . $e->getMessage() . PHP_EOL;
}To retrieve a document from the server, the get() method of the DocumentHandler class can be used. It needs the collection name plus a document id. There is also the getById() method which is an alias for get().
// get the document back from the server
$userFromServer = $handler->get('users', $id);
var_dump($userFromServer);
/*
The result of the get() method is a Document object that you can use in an OO fashion:
object(triagens\ArangoDb\Document)##6 (4) {
["_id":"triagens\ArangoDb\Document":private]=>
string(15) "2377907/4818344"
["_rev":"triagens\ArangoDb\Document":private]=>
int(4818344)
["_values":"triagens\ArangoDb\Document":private]=>
array(3) {
["age"]=>
int(25)
["name"]=>
string(4) "John"
["likes"]=>
array(3) {
[0]=>
string(7) "fishing"
[1]=>
string(6) "hiking"
[2]=>
string(8) "swimming"
}
}
["_changed":"triagens\ArangoDb\Document":private]=>
bool(false)
}
*/Whenever the document id is yet unknown, but you want to fetch a document from the server by any of its other properties, you can use the getByExample() method. It allows you to provide an example of the document that you are looking for. The example should either be a Document object with the relevant properties set, or, a PHP array with the propeties that you are looking for:
$cursor = $handler->getByExample('users', array('name' => 'John'));
var_dump($cursor->getAll());
$user = new Document();
$user->name = 'John';
$cursor = $handler->getByExample('users', $user);
var_dump($cursor->getAll());This will return all documents from the specified collection (here: "users") with the properties provided in the example (here: that have an attribute "name" with a value of "John"). The result is a cursor which can be iterated sequentially or completely. We have chosen to get the complete result set above by calling the cursor's getAll() method. Note that getByExample() might return multiple documents if the example is ambigious.
To update an existing document, the update() method of the DocumentHandler class can be used.
// update a document
$userFromServer->likes = array('fishing', 'swimming');
$userFromServer->state = 'CA';
unset($userFromServer->age);
$result = $handler->update($userFromServer);
var_dump($result);The document that is updated using update() must have been fetched from the server before. If you want to update a document without having fetched it from the server before, use updateById():
// update a document, identified by collection and document id
$user = new Document();
$user->name = 'John';
$user->likes = array('Running', 'Rowing');
// 4818344 is the document's id
$result = $handler->updateById('users', 4818344, $user);
var_dump($result);To remove an existing document on the server, the remove() method of the DocumentHandler class will do. remove() just needs the document to be removed as a parameter:
// remove a document on the server, using a document object
$result = $handler->remove($userFromServer);
var_dump($result);Note that the document must have been fetched from the server before. If you haven't fetched the document from the server before, use the removeById() method. This requires just the collection name (here: "users") and the document id.
// remove a document on the server, using a collection id and document id
// 4818344 is the document's id
$result = $handler->removeById('users', 4818344);
var_dump($result);To run an AQL query, use the Statement class:
// create a statement to insert 1000 test users
$statement = new ArangoStatement($connection, array(
'query' => 'FOR i IN 1..1000 INSERT { _key: CONCAT('test', i) } IN users'
));
// execute the statement
$cursor = $statement->execute();
// now run another query on the data, using bind parameters
$statement = new ArangoStatement($connection, array(
'query' => 'FOR u IN @@collection FILTER u.name == @name RETURN u',
'bindVars' => array(
'@collection' => 'users',
'name' => 'John'
)
));
// executing the statement returns a cursor
$cursor = $statement->execute();
// easiest way to get all results returned by the cursor
var_dump($cursor->getAll());
// to get statistics for the query, use Cursor::getExtra();
var_dump($cursor->getExtra());To export the contents of a collection to PHP, use the Export class. The Export class will create a light-weight cursor over all documents of the specified collection. The results can be transferred to PHP in chunks incrementally. This is the most efficient way of iterating over all documents in a collection.
// creates an export object for collection users
$export = new ArangoExport($connection, 'users', array());
// execute the export. this will return a special, forward-only cursor
$cursor = $export->execute();
// now we can fetch the documents from the collection in blocks
while ($docs = $cursor->getNextBatch()) {
// do something with $docs
var_dump($docs);
}
// the export can also be restricted to just a few attributes per document:
$export = new ArangoExport($connection, 'users', array(
'_flat' => true,
'restrict' => array(
'type' => "include",
'fields' => array("_key", "likes")
)
));
// now fetch just the configured attributes for each document
while ($docs = $cursor->getNextBatch()) {
// do something with $docs
var_dump($docs);
}The ArangoDB-PHP driver provides a mechanism to easily fetch multiple documents from the same collection with a single request. All that needs to be provided is an array of document keys:
$exampleCollection = new ArangoCollection();
$exampleCollection->setName('example');
$id = $collectionHandler->add($exampleCollection);
// create a statement to insert 100 example documents
$statement = new ArangoStatement($connection, array(
'query' => 'FOR i IN 1..100 INSERT { _key: CONCAT("example", i), value: i } IN example'
));
$statement->execute();
// later on, we can assemble a list of document keys
$keys = array();
for ($i = 1; $i <= 100; ++$i) {
$keys[] = 'example' . $i;
}
// and fetch all the documents at once
$documents = $collectionHandler->lookupByKeys('example', $keys);
var_dump($documents);
// we can also bulk-remove them:
$result = $collectionHandler->removeByKeys('example', $keys);
var_dump($result);To drop an existing collection on the server, use the drop() method of the CollectionHandler class. drop() just needs the name of the collection name to be dropped:
// drop a collection on the server, using its name
$result = $collectionHandler->drop('users');
var_dump($result);
// drop the other one we created, too
$collectionHandler->drop('example');The driver provides a simple logging mechanism that is turned off by default. If it is turned on, the driver
will log all its exceptions using PHP's standard error_log mechanism. It will call PHP's error_log()
function for this. It depends on the PHP configuration if and where exceptions will be logged. Please consult
your php.ini settings for further details.
To turn on exception logging in the driver, set a flag on the driver's Exception base class, from which all driver exceptions are subclassed:
use triagens\ArangoDb\Exception as ArangoException;
ArangoException::enableLogging();To turn logging off, call its disableLogging method:
use triagens\ArangoDb\Exception as ArangoException;
ArangoException::disableLogging();Here's the full code that combines all the pieces outlined above:
// use the following line when using packagist/composer
// require dirname(__FILE__) . DIRECTORY_SEPARATOR . 'vendor' . DIRECTORY_SEPARATOR . '.composer' . DIRECTORY_SEPARATOR . 'autoload.php';
// use the following line when using git
require dirname(__FILE__) . DIRECTORY_SEPARATOR . 'arangodb-php' . DIRECTORY_SEPARATOR . 'autoload.php';
// set up some aliases for less typing later
use triagens\ArangoDb\Collection as ArangoCollection;
use triagens\ArangoDb\CollectionHandler as ArangoCollectionHandler;
use triagens\ArangoDb\Connection as ArangoConnection;
use triagens\ArangoDb\ConnectionOptions as ArangoConnectionOptions;
use triagens\ArangoDb\DocumentHandler as ArangoDocumentHandler;
use triagens\ArangoDb\Document as ArangoDocument;
use triagens\ArangoDb\Exception as ArangoException;
use triagens\ArangoDb\Export as ArangoExport;
use triagens\ArangoDb\ConnectException as ArangoConnectException;
use triagens\ArangoDb\ClientException as ArangoClientException;
use triagens\ArangoDb\ServerException as ArangoServerException;
use triagens\ArangoDb\Statement as ArangoStatement;
use triagens\ArangoDb\UpdatePolicy as ArangoUpdatePolicy;
// set up some basic connection options
$connectionOptions = array(
// database name
ArangoConnectionOptions::OPTION_DATABASE => '_system',
// server endpoint to connect to
ArangoConnectionOptions::OPTION_ENDPOINT => 'tcp://127.0.0.1:8529',
// authorization type to use (currently supported: 'Basic')
ArangoConnectionOptions::OPTION_AUTH_TYPE => 'Basic',
// user for basic authorization
ArangoConnectionOptions::OPTION_AUTH_USER => 'root',
// password for basic authorization
ArangoConnectionOptions::OPTION_AUTH_PASSWD => '',
// connection persistence on server. can use either 'Close' (one-time connections) or 'Keep-Alive' (re-used connections)
ArangoConnectionOptions::OPTION_CONNECTION => 'Keep-Alive',
// connect timeout in seconds
ArangoConnectionOptions::OPTION_TIMEOUT => 3,
// whether or not to reconnect when a keep-alive connection has timed out on server
ArangoConnectionOptions::OPTION_RECONNECT => true,
// optionally create new collections when inserting documents
ArangoConnectionOptions::OPTION_CREATE => true,
// optionally create new collections when inserting documents
ArangoConnectionOptions::OPTION_UPDATE_POLICY => ArangoUpdatePolicy::LAST,
);
// turn on exception logging (logs to whatever PHP is configured)
ArangoException::enableLogging();
try {
$connection = new ArangoConnection($connectionOptions);
$collectionHandler = new ArangoCollectionHandler($connection);
// clean up first
if ($collectionHandler->has('users')) {
$collectionHandler->drop('users');
}
if ($collectionHandler->has('example')) {
$collectionHandler->drop('example');
}
// create a new collection
$userCollection = new ArangoCollection();
$userCollection->setName('users');
$id = $collectionHandler->add($userCollection);
// print the collection id created by the server
var_dump($id);
// check if the collection exists
$result = $collectionHandler->has('users');
var_dump($result);
$handler = new ArangoDocumentHandler($connection);
// create a new document
$user = new ArangoDocument();
// use set method to set document properties
$user->set("name", "John");
$user->set("age", 25);
// use magic methods to set document properties
$user->likes = array('fishing', 'hiking', 'swimming');
// send the document to the server
$id = $handler->add('users', $user);
// check if a document exists
$result = $handler->has("users", $id);
var_dump($result);
// print the document id created by the server
var_dump($id);
var_dump($user->getId());
// get the document back from the server
$userFromServer = $handler->get('users', $id);
var_dump($userFromServer);
// get a document list back from the server, using a document example
$cursor = $handler->getByExample('users', array('name' => 'John'));
var_dump($cursor->getAll());
// update a document
$userFromServer->likes = array('fishing', 'swimming');
$userFromServer->state = 'CA';
unset($userFromServer->age);
$result = $handler->update($userFromServer);
var_dump($result);
// get the document back from the server
$userFromServer = $handler->get('users', $id);
var_dump($userFromServer);
// remove a document on the server
$result = $handler->remove($userFromServer);
var_dump($result);
// create a statement to insert 1000 test users
$statement = new ArangoStatement($connection, array(
'query' => 'FOR i IN 1..1000 INSERT { _key: CONCAT("test", i) } IN users'
));
// execute the statement
$cursor = $statement->execute();
// now run another query on the data, using bind parameters
$statement = new ArangoStatement($connection, array(
'query' => 'FOR u IN @@collection FILTER u.name == @name RETURN u',
'bindVars' => array(
'@collection' => 'users',
'name' => 'John'
)
));
// executing the statement returns a cursor
$cursor = $statement->execute();
// easiest way to get all results returned by the cursor
var_dump($cursor->getAll());
// to get statistics for the query, use Cursor::getExtra();
var_dump($cursor->getExtra());
// creates an export object for collection users
$export = new ArangoExport($connection, 'users', array());
// execute the export. this will return a special, forward-only cursor
$cursor = $export->execute();
// now we can fetch the documents from the collection in blocks
while ($docs = $cursor->getNextBatch()) {
// do something with $docs
var_dump($docs);
}
// the export can also be restricted to just a few attributes per document:
$export = new ArangoExport($connection, 'users', array(
'_flat' => true,
'restrict' => array(
'type' => "include",
'fields' => array("_key", "likes")
)
));
// now fetch just the configured attributes for each document
while ($docs = $cursor->getNextBatch()) {
// do something with $docs
var_dump($docs);
}
$exampleCollection = new ArangoCollection();
$exampleCollection->setName('example');
$id = $collectionHandler->add($exampleCollection);
// create a statement to insert 100 example documents
$statement = new ArangoStatement($connection, array(
'query' => 'FOR i IN 1..100 INSERT { _key: CONCAT("example", i), value: i } IN example'
));
$statement->execute();
// later on, we can assemble a list of document keys
$keys = array();
for ($i = 1; $i <= 100; ++$i) {
$keys[] = 'example' . $i;
}
// and fetch all the documents at once
$documents = $collectionHandler->lookupByKeys('example', $keys);
var_dump($documents);
// we can also bulk-remove them:
$result = $collectionHandler->removeByKeys('example', $keys);
var_dump($result);
// drop a collection on the server, using its name,
$result = $collectionHandler->drop('users');
var_dump($result);
// drop the other one we created, too
$collectionHandler->drop('example');
}
catch (ArangoConnectException $e) {
print 'Connection error: ' . $e->getMessage() . PHP_EOL;
}
catch (ArangoClientException $e) {
print 'Client error: ' . $e->getMessage() . PHP_EOL;
}
catch (ArangoServerException $e) {
print 'Server error: ' . $e->getServerCode() . ': ' . $e->getServerMessage() . ' - ' . $e->getMessage() . PHP_EOL;
}-
More example code, containing some code to create, delete and rename collections, is provided in the examples subdirectory that is provided with the library.
-
PHPDoc documentation for the complete library is in the library's docs subdirectory. Point your browser at this directory to get a click-through version of the documentation.
-
Follow us on Twitter @arangodbphp to receive updates on the PHP driver
-
Check the ArangoDB PHP client on github.com regularly for new releases and updates: https://github.com/arangodb/arangodb-php