Method SyncDBSchema

backend/plugin/db/sqlite/sync.go:50–97

SyncDBSchema syncs a single database schema.

(ctx context.Context)

// SyncDBSchema syncs a single database schema.
func (d *Driver) SyncDBSchema(ctx context.Context) (*storepb.DatabaseSchemaMetadata, error) {
	databases, err := d.getDatabases()
	if err != nil {
		return nil, err
	}

	schemaMetadata := &storepb.SchemaMetadata{
		Name: "",
	}
	databaseMetadata := &storepb.DatabaseSchemaMetadata{
		Name:    d.databaseName,
		Schemas: []*storepb.SchemaMetadata{schemaMetadata},
	}
	found := false
	for _, database := range databases {
		if database == d.databaseName {
			found = true
			break
		}
	}
	if !found {
		return nil, common.Errorf(common.NotFound, "database %q not found", d.databaseName)
	}

	txn, err := d.db.BeginTx(ctx, &sql.TxOptions{ReadOnly: true})
	if err != nil {
		return nil, err
	}
	defer txn.Rollback()

	tables, err := getTables(txn)
	if err != nil {
		return nil, err
	}
	schemaMetadata.Tables = tables

	views, err := getViews(txn)
	if err != nil {
		return nil, err
	}
	schemaMetadata.Views = views

	if err := txn.Commit(); err != nil {
		return nil, err
	}

	return databaseMetadata, nil
}

// getTables gets all tables of a database.
func getTables(txn *sql.Tx) ([]*storepb.TableMetadata, error) {