Function readSchema

dgraph/cmd/bulk/loader.go:296–326

(opt *BulkOptions)

}

func readSchema(opt *BulkOptions) *schema.ParsedSchema {
	if opt.SchemaFile == "" {
		return genDQLSchema(opt)
	}

	f, err := filestore.Open(opt.SchemaFile)
	x.Check(err)
	defer func() {
		if err := f.Close(); err != nil {
			glog.Warningf("error while closing fd: %v", err)
		}
	}()

	key := opt.EncryptionKey
	if !opt.Encrypted {
		key = nil
	}
	r, err := enc.GetReader(key, f)
	x.Check(err)
	if filepath.Ext(opt.SchemaFile) == ".gz" {
		r, err = gzip.NewReader(r)
		x.Check(err)
	}

	buf, err := io.ReadAll(r)
	x.Check(err)

	result, err := schema.ParseWithNamespace(string(buf), opt.Namespace)
	x.Check(err)
	return result
}

func genDQLSchema(opt *BulkOptions) *schema.ParsedSchema {
	gqlSchBytes := readGqlSchema(opt)