add rocksdb

Author: matyhtf

examples/rocksdb

@@ -0,0 +1,7 @@
+/.idea
+/cmake-build-debug/
+/db
+.cproject
+*.so
+.project
+.settings

examples/rocksdb/.gitignore

@@ -0,0 +1,12 @@
+PHP_INCLUDE = `php-config --includes`
+PHP_LIBS = `php-config --libs`
+PHP_LDFLAGS = `php-config --ldflags`
+PHP_INCLUDE_DIR = `php-config --include-dir`
+PHP_EXTENSION_DIR = `php-config --extension-dir`
+
+php-rocksdb.so: rocksdb.cpp
+	c++ -DHAVE_CONFIG_H -g -o php-rocksdb.so -O0 -fPIC -shared rocksdb.cpp -std=c++11 -lphpx -lrocksdb  ${PHP_INCLUDE} -I${PHP_INCLUDE_DIR}
+install: php-rocksdb.so
+	cp php-rocksdb.so ${PHP_EXTENSION_DIR}/
+clean:
+	rm *.so

examples/rocksdb/Makefile

@@ -0,0 +1,33 @@
+<?php
+$config = array(
+		'options' => array(
+				'create_if_missing' => true,    // if the specified database didn't exist will create a new one
+				'error_if_exists' => false,   // if the opened database exsits will throw exception
+				'paranoid_checks' => false,
+				'paranoid_checks' => false,
+				'merge_operator' => ',',
+		),
+		/* default readoptions */
+		'readoptions' => array(
+				'verify_check_sum' => false,
+				'fill_cache' => true,
+		),
+		/* default write options */
+		'writeoptions' => array(
+				'sync' => false
+		),
+);
+$db_name = dirname(__DIR__)."/db/test6";
+$r = new RocksDB($db_name, $config['options'], $config['readoptions'], $config['writeoptions']);
+
+$key = "key_test";
+$r->put($key, "hello world");
+
+$key = "key_test";
+$res = $r->get($key);
+echo "get {$key} res:".var_export($res,1)."\n";
+
+$r->delete($key);
+
+$res = $r->get($key);
+echo "get {$key} res:".var_export($res,1)."\n";

examples/rocksdb/examples/del.php

@@ -0,0 +1,26 @@
+<?php
+$config = array(
+		'options' => array(
+				'create_if_missing' => true,    // if the specified database didn't exist will create a new one
+				'error_if_exists' => false,   // if the opened database exsits will throw exception
+				'paranoid_checks' => false,
+				'paranoid_checks' => false,
+				'merge_operator' => ',',
+		),
+		/* default readoptions */
+		'readoptions' => array(
+				'verify_check_sum' => false,
+				'fill_cache' => true,
+		),
+		/* default write options */
+		'writeoptions' => array(
+				'sync' => false
+		),
+);
+$db_name = dirname(__DIR__)."/db/test6";
+$r = new RocksDB($db_name, $config['options'], $config['readoptions'], $config['writeoptions']);
+
+$key = "key_test";
+$r->put($key, "hello world");
+$res = $r->get($key);
+echo "get {$key} res:".var_export($res,1)."\n";

examples/rocksdb/examples/get.php

@@ -0,0 +1,57 @@
+/**
+ * A MergeOperator for rocksdb that implements string append.
+ * @author Deon Nicholas ([email protected])
+ * Copyright 2013 Facebook
+ */
+
+#include "stringappend.h"
+
+#include <memory>
+#include <assert.h>
+
+#include "rocksdb/slice.h"
+#include "rocksdb/merge_operator.h"
+#include "utilities/merge_operators.h"
+
+namespace rocksdb {
+
+// Constructor: also specify the delimiter character.
+StringAppendOperator::StringAppendOperator(char delim_char)
+    : delim_(delim_char) {
+}
+
+// Implementation for the merge operation (concatenates two strings)
+bool StringAppendOperator::Merge(const Slice& key,
+                                 const Slice* existing_value,
+                                 const Slice& value,
+                                 std::string* new_value,
+                                 Logger* logger) const {
+
+  // Clear the *new_value for writing.
+  assert(new_value);
+  new_value->clear();
+
+  if (!existing_value) {
+    // No existing_value. Set *new_value = value
+    new_value->assign(value.data(),value.size());
+  } else {
+    // Generic append (existing_value != null).
+    // Reserve *new_value to correct size, and apply concatenation.
+    new_value->reserve(existing_value->size() + 1 + value.size());
+    new_value->assign(existing_value->data(),existing_value->size());
+    new_value->append(1,delim_);
+    new_value->append(value.data(), value.size());
+  }
+
+  return true;
+}
+
+const char* StringAppendOperator::Name() const  {
+  return "StringAppendOperator";
+}
+
+std::shared_ptr<MergeOperator> MergeOperators::CreateStringAppendOperator() {
+  return std::make_shared<StringAppendOperator>(',');
+}
+
+} // namespace rocksdb

examples/rocksdb/merge_operators/stringappend.cc

@@ -0,0 +1,31 @@
+/**
+ * A MergeOperator for rocksdb that implements string append.
+ * @author Deon Nicholas ([email protected])
+ * Copyright 2013 Facebook
+ */
+
+#pragma once
+#include "rocksdb/merge_operator.h"
+#include "rocksdb/slice.h"
+
+namespace rocksdb {
+
+class StringAppendOperator : public AssociativeMergeOperator {
+ public:
+  // Constructor: specify delimiter
+  explicit StringAppendOperator(char delim_char);
+
+  virtual bool Merge(const Slice& key,
+                     const Slice* existing_value,
+                     const Slice& value,
+                     std::string* new_value,
+                     Logger* logger) const override;
+
+  virtual const char* Name() const override;
+
+ private:
+  char delim_;         // The delimiter is inserted between elements
+
+};
+
+} // namespace rocksdb