Method Init

driver/registry_sql.go:175–250

(
	ctx context.Context,
	skipNetworkInit bool,
	migrate bool,
	extraMigrations []fs.FS,
	goMigrations []popx.Migration,
)

}

func (m *RegistrySQL) Init(
	ctx context.Context,
	skipNetworkInit bool,
	migrate bool,
	extraMigrations []fs.FS,
	goMigrations []popx.Migration,
) error {
	if m.basePersister == nil {
		if m.Config().CGroupsV1AutoMaxProcsEnabled() {
			_, err := maxprocs.Set(maxprocs.Logger(m.Logger().Infof))
			if err != nil {
				return fmt.Errorf("could not set GOMAXPROCS: %w", err)
			}
		}

		// new db connection
		pool, idlePool, connMaxLifetime, connMaxIdleTime, cleanedDSN := sqlcon.ParseConnectionOptions(
			m.l, m.Config().DSN(),
		)

		opts := &pop.ConnectionDetails{
			URL:             sqlcon.FinalizeDSN(m.l, cleanedDSN),
			IdlePool:        idlePool,
			ConnMaxLifetime: connMaxLifetime,
			ConnMaxIdleTime: connMaxIdleTime,
			Pool:            pool,
			TracerProvider:  m.Tracer(ctx).Provider(),
			Unsafe:          m.Config().DbIgnoreUnknownTableColumns(),
		}

		for _, f := range m.dbOptsModifier {
			f(opts)
		}

		c, err := pop.NewConnection(opts)
		if err != nil {
			return errors.WithStack(err)
		}
		if err := resilience.Retry(m.l, 5*time.Second, 5*time.Minute, c.Open); err != nil {
			return errors.WithStack(err)
		}

		m.basePersister = sql.NewBasePersister(c, m)
		if err := m.initialPing(ctx, m.Logger(), m.basePersister); err != nil {
			m.Logger().Print("Could not ping database: ", err)
			return err
		}

		m.migrator = sql.NewMigrationManager(c, m, extraMigrations, goMigrations)

		// if dsn is memory we have to run the migrations on every start
		// use case - such as
		// - just in memory
		// - shared connection
		// - shared but unique in the same process
		// see: https://sqlite.org/inmemorydb.html
		switch {
		case dbal.IsMemorySQLite(m.Config().DSN()):