DSE 6.8 version of https://github.com/datastax/nodejs-driver/blob/master/examples/graph/intro.js

intro.js

/*
 * Copyright DataStax, Inc.
 *
 * Licensed 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
 *
 * http://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.
 */
'use strict';
const cassandra = require('cassandra-driver');
const async = require('async');

/**
 * Example using async library for avoiding nested callbacks
 * See https://github.com/caolan/async
 *
 * Inserts some vertex and edges: http://tinkerpop.apache.org/docs/3.1.1-incubating/reference/#_the_graph_structure
 */

const client = new cassandra.Client({
  contactPoints: ['127.0.0.1'],
  // newer version of the driver requires to set localDataCenter
  localDataCenter: 'dc1',
  profiles: [
    // Set the graph name in the default execution profile
    // DSE 6.8 uses GraphSON 3.0 to serialize results
    new cassandra.ExecutionProfile('default', {
      graphOptions: { name: 'example_graph', results: 'graphson-3.0' }
    })
  ]
});

// Schema API changed for new DSE Graph engine
const modernSchema =
  'schema.vertexLabel("person").ifNotExists().partitionBy("name", Text).property("age", Int).create();\n' +
  'schema.edgeLabel("knows").ifNotExists().from("person").to("person").property("relationship_weight", Float).create();';

// DSE 6.8 no longer can use graph API
const modernGraph =
  'g.addV("person").property("name", "marko").property("age", 29).as("m").\n' +
  '  V().addV("person").property("name", "vadas").property("age", 27).\n' +
  '  addE("knows").property("relationship_weight", 0.5f).from("m");\n';

async.series([
  function connect(next) {
    client.connect(next);
  },
  function createGraph(next) {
    const query = 'system.graph("example_graph").ifNotExists().create();';
    // As the graph "example_graph" does not exist yet and
    // it is a system query, we need to set the graph name to `null`
    client.executeGraph(query, null, { graphName: null }, next);
  },
  function createSchema(next) {
    client.executeGraph(modernSchema, next);
  },
  function createVerticesAndEdges(next) {
    client.executeGraph(modernGraph, next);
  },
  function retrieveVertices(next) {
    // when you need to scan graph, use with('allow-filtering')
    client.executeGraph('g.with("allow-filtering").V()', function (err, result) {
      if (err) {
        return next(err);
      }
      const vertex = result.first();
      console.log('First vertex: ', vertex);
      next();
    });
  }
], function (err) {
  if (err) {
    console.error('There was an error', err.message, err.stack);
  }
  console.log('Shutting down');
  client.shutdown();
});