1 files changed, 92 insertions, 0 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoimport/main/mongoimport.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoimport/main/mongoimport.go
new file mode 100644
index 00000000000..c608e68cbda
--- /dev/null
+++ b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoimport/main/mongoimport.go
@@ -0,0 +1,92 @@
+// Copyright (C) MongoDB, Inc. 2014-present.
+//
+// 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
+
+// Main package for the mongoimport tool.
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/mongodb/mongo-tools/common/db"
+	"github.com/mongodb/mongo-tools/common/log"
+	"github.com/mongodb/mongo-tools/common/options"
+	"github.com/mongodb/mongo-tools/common/signals"
+	"github.com/mongodb/mongo-tools/common/util"
+	"github.com/mongodb/mongo-tools/mongoimport"
+)
+
+func main() {
+	// initialize command-line opts
+	opts := options.New("mongoimport", mongoimport.Usage,
+		options.EnabledOptions{Auth: true, Connection: true, Namespace: true, URI: true})
+
+	inputOpts := &mongoimport.InputOptions{}
+	opts.AddOptions(inputOpts)
+	ingestOpts := &mongoimport.IngestOptions{}
+	opts.AddOptions(ingestOpts)
+	opts.URI.AddKnownURIParameters(options.KnownURIOptionsWriteConcern)
+
+	args, err := opts.ParseArgs(os.Args[1:])
+	if err != nil {
+		log.Logvf(log.Always, "error parsing command line options: %v", err)
+		log.Logvf(log.Always, "try 'mongoimport --help' for more information")
+		os.Exit(util.ExitBadOptions)
+	}
+
+	log.SetVerbosity(opts.Verbosity)
+	signals.Handle()
+
+	// print help, if specified
+	if opts.PrintHelp(false) {
+		return
+	}
+
+	// print version, if specified
+	if opts.PrintVersion() {
+		return
+	}
+
+	// verify uri options and log them
+	opts.URI.LogUnsupportedOptions()
+
+	// create a session provider to connect to the db
+	sessionProvider, err := db.NewSessionProvider(*opts)
+	if err != nil {
+		log.Logvf(log.Always, "error connecting to host: %v", err)
+		os.Exit(util.ExitError)
+	}
+	defer sessionProvider.Close()
+	sessionProvider.SetBypassDocumentValidation(ingestOpts.BypassDocumentValidation)
+
+	m := mongoimport.MongoImport{
+		ToolOptions:     opts,
+		InputOptions:    inputOpts,
+		IngestOptions:   ingestOpts,
+		SessionProvider: sessionProvider,
+	}
+
+	if err = m.ValidateSettings(args); err != nil {
+		log.Logvf(log.Always, "error validating settings: %v", err)
+		log.Logvf(log.Always, "try 'mongoimport --help' for more information")
+		os.Exit(util.ExitError)
+	}
+
+	numDocs, err := m.ImportDocuments()
+	if !opts.Quiet {
+		if err != nil {
+			log.Logvf(log.Always, "Failed: %v", err)
+		}
+		message := fmt.Sprintf("imported 1 document")
+		if numDocs != 1 {
+			message = fmt.Sprintf("imported %v documents", numDocs)
+		}
+		log.Logvf(log.Always, message)
+	}
+	if err != nil {
+		os.Exit(util.ExitError)
+	}
+}