diff --git a/apps/db-adapter/internal/memgraph/create_schema.go b/apps/db-adapter/internal/memgraph/create_schema.go deleted file mode 100644 index ba76245..0000000 --- a/apps/db-adapter/internal/memgraph/create_schema.go +++ /dev/null @@ -1,66 +0,0 @@ -package memgraph - -import ( - "time" - - "github.com/neo4j/neo4j-go-driver/v5/neo4j" - "golang.org/x/net/context" -) - -const dbCreateSchemaTimeout = 10 * time.Second - -func createIndexes(driver neo4j.DriverWithContext) error { - ctx, cancel := context.WithTimeout(context.Background(), dbCreateSchemaTimeout) - defer cancel() - - session := driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeWrite}) - defer session.Close(ctx) - - indexes := []string{ - `CREATE INDEX ON :Person(id);`, - `CREATE INDEX ON :Person(last_name);`, - `CREATE INDEX ON :Person(first_name);`, - `CREATE INDEX ON :Person(born);`, - `CREATE INDEX ON :Person(mothers_first_name);`, - `CREATE INDEX ON :Person(mothers_last_name);`, - } - - // Run index queries via implicit auto-commit transaction - for _, index := range indexes { - _, err := session.Run(ctx, index, nil) - if err != nil { - return err - } - } - - return nil -} - -func createConstraints(driver neo4j.DriverWithContext) error { - ctx, cancel := context.WithTimeout(context.Background(), dbCreateSchemaTimeout) - defer cancel() - - session := driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeWrite}) - defer session.Close(ctx) - - constraints := []string{ - `CREATE CONSTRAINT ON (n:Person) ASSERT EXISTS (n.id);`, - `CREATE CONSTRAINT ON (n:Person) ASSERT EXISTS (n.last_name);`, - `CREATE CONSTRAINT ON (n:Person) ASSERT EXISTS (n.first_name);`, - `CREATE CONSTRAINT ON (n:Person) ASSERT EXISTS (n.born);`, - `CREATE CONSTRAINT ON (n:Person) ASSERT EXISTS (n.mothers_first_name);`, - `CREATE CONSTRAINT ON (n:Person) ASSERT EXISTS (n.mothers_last_name);`, - `CREATE CONSTRAINT ON (n:Person) ASSERT n.id IS UNIQUE;`, - `CREATE CONSTRAINT ON (n:Person) ASSERT n.last_name, n.first_name, n.born, n.mothers_first_name, n.mothers_last_name IS UNIQUE;`, - } - - // Run index queries via implicit auto-commit transaction - for _, constraint := range constraints { - _, err := session.Run(ctx, constraint, nil) - if err != nil { - return err - } - } - - return nil -} diff --git a/apps/db-adapter/internal/memgraph/init_database.go b/apps/db-adapter/internal/memgraph/init_database.go index 9a2f545..9b0350f 100644 --- a/apps/db-adapter/internal/memgraph/init_database.go +++ b/apps/db-adapter/internal/memgraph/init_database.go @@ -20,13 +20,5 @@ func InitDatabase(dbURI, dbUser, dbPassword string) neo4j.DriverWithContext { log.Panicln(err) } - if err := createIndexes(driver); err != nil { - log.Panicln(err) - } - - if err := createConstraints(driver); err != nil { - log.Panicln(err) - } - return driver }