start implement json load

cmd/root.go

@@ -6,6 +6,7 @@ import (
 	_ "net/http/pprof" // enable pprof via a flag
 	"os"
 
+	"github.com/bmeg/grip/cmd/caliperload"
 	"github.com/bmeg/grip/cmd/create"
 	"github.com/bmeg/grip/cmd/delete"
 	"github.com/bmeg/grip/cmd/drop"
@@ -60,6 +61,7 @@ func init() {
 	RootCmd.AddCommand(job.Cmd)
 	RootCmd.AddCommand(load.Cmd)
 	RootCmd.AddCommand(mongoload.Cmd)
+	RootCmd.AddCommand(caliperload.Cmd)
 	RootCmd.AddCommand(query.Cmd)
 	RootCmd.AddCommand(erclient.Cmd)
 	RootCmd.AddCommand(rdf.Cmd)

cmd/schema/main.go

@@ -63,7 +63,7 @@ var getCmd = &cobra.Command{
 	},
 }
 
-var loadPrimitiveSchemafromJsonSchema = &cobra.Command{
+var loadGqlSchemafromJsonSchema = &cobra.Command{
 	Use:   "load",
 	Short: "Load graph schemas",
 	Long:  ``,
@@ -221,12 +221,12 @@ func init() {
 	pflags.StringVar(&yamlSchemaDir, "yamlSchemaDir", "", "Name of YAML schemas dir")
 	pflags.StringVar(&graphName, "graphName", "", "Name of schemaGraph")
 
-	sflags := loadPrimitiveSchemafromJsonSchema.Flags()
-	sflags.StringVar(&jsonSchemaFile, "jsonSchema", "", "Json Schema")
-	sflags.StringVar(&yamlSchemaDir, "yamlSchemaDir", "", "Name of YAML schemas dir")
-	sflags.StringVar(&graphName, "graphName", "", "Name of schemaGraph")
+	gqlflags := loadGqlSchemafromJsonSchema.Flags()
+	gqlflags.StringVar(&jsonSchemaFile, "jsonSchema", "", "Json Schema")
+	gqlflags.StringVar(&yamlSchemaDir, "yamlSchemaDir", "", "Name of YAML schemas dir")
+	gqlflags.StringVar(&graphName, "graphName", "", "Name of schemaGraph")
 
-	Cmd.AddCommand(loadPrimitiveSchemafromJsonSchema)
+	Cmd.AddCommand(loadGqlSchemafromJsonSchema)
 	Cmd.AddCommand(getCmd)
 	Cmd.AddCommand(postCmd)
 }

gripql/client.go

@@ -181,6 +181,21 @@ func (client Client) BulkAdd(elemChan chan *GraphElement) error {
 	return err
 }
 
+func (client Client) BulkAddRaw(elemChan chan *RawJson) error {
+	sc, err := client.EditC.BulkAddRaw(context.Background())
+	if err != nil {
+		return err
+	}
+	for elem := range elemChan {
+		err := sc.Send(elem)
+		if err != nil {
+			return err
+		}
+	}
+	_, err = sc.CloseAndRecv()
+	return err
+}
+
 func (client Client) BulkDelete(delete *DeleteData) error {
 	_, err := client.EditC.BulkDelete(context.Background(), delete)
 	return err