export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64
export PATH=$JAVA_HOME/bin:$PATH
java -jar /opt/rya/rya-project/extras/shell/target/rya.shell-4.0.1-shaded.jar

 _____                _____ _          _ _
|  __ \              / ____| |        | | |
| |__) |   _  __ _  | (___ | |__   ___| | |
|  _  / | | |/ _` |  \___ \| '_ \ / _ \ | |
| | \ \ |_| | (_| |  ____) | | | |  __/ | |
|_|  \_\__, |\__,_| |_____/|_| |_|\___|_|_|
        __/ |
       |___/
4.0.1

Welcome to the Rya Shell.

Execute one of the connect commands to start interacting with an instance of Rya.
You may press tab at any time to see which of the commands are available.

rya> help
* ! - Allows execution of operating system (OS) commands
* // - Inline comment markers (start of line only)
* ; - Inline comment markers (start of line only)
* add-user - Adds an authorized user to the Rya instance.
* clear - Clears the console
* cls - Clears the console
* connect-accumulo - Connect the shell to an instance of Accumulo.
* connect-mongo - Connect the shell to an instance of MongoDB.
* connect-rya - Connect to a specific Rya instance
* create-pcj - Creates and starts the maintenance of a new PCJ using a Fluo application.
* create-periodic-pcj - Creates and starts the maintenance of a new Periodic PCJ and registers the associated Periodic Notification with Kafka.
* date - Displays the local date and time
* delete-pcj - Deletes and halts maintenance of a PCJ.
* delete-periodic-pcj - Deletes and halts maintenance of a Periodic PCJ.
* disconnect - Disconnect the shell's Rya storage connection (Accumulo).
* exit - Exits the shell
* help - List all commands usage
* install - Create a new instance of Rya interactively.
* install-with-accumulo-parameters - Create a new Accumulo instance of Rya with command line parameters.
* install-with-mongo-parameters - Create a new MongoDB instance of Rya with command line parameters.
* list-incremental-queries - Lists relevant information about all SPARQL queries maintained by the Fluo application.
* list-instances - List the names of the installed Rya instances.
* load-data - Loads RDF Statement data from a local file to the connected Rya instance.
* print-connection-details - Print information about the Shell's Rya storage connection.
* print-instance-details - Print information about how the Rya instance is configured.
* quit - Exits the shell
* remove-user - Removes an authorized user from the Rya instance.
* script - Parses the specified resource file and executes its commands
* sparql-query - Executes the provided SPARQL Query on the connected Rya instance.
* streams-configure - Connect a Rya Streams subsystem to a Rya Instance.
* streams-details - Print information about which Rya Streams subsystem the Rya instance is connected to.
* streams-queries-add - Add a SPARQL query to the Rya Streams subsystem.
* streams-queries-delete - Delete a SPARQL query from the Rya Streams subsystem.
* streams-queries-details - Print detailed information about a specific query managed by the Rya Streams subsystem.
* streams-queries-list - List the queries that are being managed by the configured Rya Streams subsystem.
* streams-queries-start - Start processing a SPARQL query using the Rya Streams subsystem.
* streams-queries-stop - Stop processing a SPARQL query using the Rya Streams subsystem.
* system properties - Shows the shell's properties
* uninstall - Uninstall an instance of Rya.
* version - Displays shell version

printf 'connect-accumulo --username root --instanceName miniInstance --zookeepers localhost:26007\nq1w2e3r4\ninstall-with-accumulo-parameters --instanceName rya_shell_demo\ny\nconnect-rya --instance rya_shell_demo\nload-data --file /opt/rya/shell-test/triples.nt\nsparql-query --file /opt/rya/shell-test/query.sparql\nexit\n' | java -jar rya.shell-4.0.1-shaded.jar

rya> connect-accumulo --username root --instanceName miniInstance --zookeepers localhost:26007
Password: ********
Connected. You must select a Rya instance to interact with next.
rya/miniInstance> install-with-accumulo-parameters --instanceName rya_shell_demo

A Rya instance will be installed using the following values:
   Instance Name: rya_shell_demo
   Use Shard Balancing: false
   Use Entity Centric Indexing: false
   Use Free Text Indexing: false
   Use Temporal Indexing: false
   Use Precomputed Join Indexing: false

Continue with the install? (y/n) y
The Rya instance named 'rya_shell_demo' has been installed.
rya/miniInstance> connect-rya --instance rya_shell_demo
rya/miniInstance:rya_shell_demo> load-data --file /opt/rya/shell-test/triples.nt
Loaded the file: '/opt/rya/shell-test/triples.nt' successfully in 0.101 seconds.
rya/miniInstance:rya_shell_demo> sparql-query --file /opt/rya/shell-test/query.sparql
Executing Query...
Query Results:
name,thing
"Thing 1",http://Thing1
"Thing 3",http://Thing3
Done.
rya/miniInstance:rya_shell_demo> exit

rya/miniInstance> list-instances
Rya instance names:
   rya_shell_demo

rya/miniInstance> print-connection-details
The shell is connected to an instance of Accumulo using the following parameters:
    Username: root
    Instance Name: miniInstance
    Zookeepers: localhost:26007

rya/miniInstance:rya_shell_demo> print-instance-details
General Metadata:
  Instance Name: rya_shell_demo
  RYA Version: 4.0.1
  Users: root
Secondary Indicies:
  Entity Centric Index:
    Enabled: false
  Free Text Index:
    Enabled: false
  Temporal Index:
    Enabled: false
  PCJ Index:
    Enabled: false

final AccumuloConnectionDetails connectionDetails =
        new AccumuloConnectionDetails(username, password.toCharArray(), cluster.getInstanceName(), cluster.getZooKeepers());
final RyaClient ryaClient = AccumuloRyaClientFactory.build(connectionDetails, connector);

import org.apache.rya.api.client.Install.InstallConfiguration;

// 默认配置安装（不启用附加索引）
ryaClient.getInstall().install("rya_demo", InstallConfiguration.builder().build());

// 启用全部附加索引
InstallConfiguration config = InstallConfiguration.builder()
        .setEnableTableHashPrefix(true)
        .setEnableEntityCentricIndex(true)
        .setEnableGeoIndex(true)
        .setEnableFreeTextIndex(true)
        .setEnableTemporalIndex(true)
        .setEnablePcjIndex(true)
        .setFluoPcjAppName("demoInstance_pcjUpdater")
        .build();

import org.eclipse.rdf4j.model.Statement;
import org.eclipse.rdf4j.model.ValueFactory;
import org.eclipse.rdf4j.model.impl.SimpleValueFactory;
import org.eclipse.rdf4j.query.BindingSet;
import org.eclipse.rdf4j.query.TupleQueryResult;

// 写入
final ValueFactory vf = SimpleValueFactory.getInstance();
final List<Statement> statements = new ArrayList<Statement>();
statements.add(vf.createStatement(vf.createIRI("http://Eve"), vf.createIRI("http://talksTo"), vf.createIRI("http://Bob")));
ryaClient.getLoadStatements().loadStatements("rya_demo", statements);

// 查询（返回 RDF4J TupleQueryResult，遍历 BindingSet）
final String sparql = "SELECT ?patron ?employee WHERE { ?patron <http://talksTo> ?employee. ?employee <http://worksAt> <http://CoffeeShop>. }";
final TupleQueryResult result = ryaClient.getExecuteSparqlQuery().executeSparqlQuery("rya_demo", sparql);
while (result.hasNext()) {
    final BindingSet bs = result.next();
    System.out.println("patron=" + bs.getValue("patron") + ", employee=" + bs.getValue("employee"));
}
result.close();