export function sqlToGraph()

in src/commands/sqlToGraph.ts [24:53]

• 29 lines of code
• 2 McCabe index (conditional complexity)

export function sqlToGraph(
  sqlConfig: any,
  query: string,
  template: string,
  graphConfig: any,
  callback?: (err: any) => void
) {
  const sqlConnector = new SQLInputConnnector(sqlConfig);
  const graphConnector = new GremlinConnector(graphConfig);

  async.waterfall(
    [
      (cb: any) => {
        sqlConnector.queryDatabase(query, cb);
      },
      (rows: any[], cb: any) => {
        const transformer = new Transformer({});
        const result = transformer.transformJSON(template, rows, graphSchema);
        graphConnector.createGraph(result, cb);
      },
    ],
    err => {
      sqlConnector.closeConnection();
      graphConnector.closeConnection();
      if (callback) {
        callback(err);
      }
    }
  );
}