Function getConstraints

backend/plugin/db/oracle/sync.go:620–762

(txn *sql.Tx, schemaName string)

}

func getConstraints(txn *sql.Tx, schemaName string) (
	map[db.TableKey][]*storepb.IndexMetadata,
	map[db.TableKey][]*storepb.CheckConstraintMetadata,
	map[db.TableKey][]*storepb.ForeignKeyMetadata,
	map[db.IndexKey]bool,
	error,
) {
	queryConstraintColumns := fmt.Sprintf(`
		SELECT
			TABLE_NAME,
			CONSTRAINT_NAME,
			COLUMN_NAME
		FROM SYS.ALL_CONS_COLUMNS
		WHERE OWNER = '%s'
		ORDER BY TABLE_NAME, CONSTRAINT_NAME, POSITION`, schemaName)

	slog.Debug("running get constraint columns query")
	constraintColumnRows, err := txn.Query(queryConstraintColumns)
	if err != nil {
		return nil, nil, nil, nil, util.FormatErrorWithQuery(err, queryConstraintColumns)
	}
	defer constraintColumnRows.Close()
	constraintColumnMap := make(map[db.ConstraintKey][]string)
	constraintTableMap := make(map[db.ConstraintKey]string)
	for constraintColumnRows.Next() {
		var tableName, constraintName string
		var columnName sql.NullString
		if err := constraintColumnRows.Scan(&tableName, &constraintName, &columnName); err != nil {
			return nil, nil, nil, nil, err
		}
		key := db.ConstraintKey{Schema: schemaName, Constraint: constraintName}
		if columnName.Valid {
			constraintColumnMap[key] = append(constraintColumnMap[key], columnName.String)
		}
		constraintTableMap[key] = tableName
	}
	if err := constraintColumnRows.Err(); err != nil {
		return nil, nil, nil, nil, util.FormatErrorWithQuery(err, queryConstraintColumns)
	}

	queryConstraints := fmt.Sprintf(`
		SELECT
			TABLE_NAME,
			CONSTRAINT_NAME,
			CONSTRAINT_TYPE,
			SEARCH_CONDITION,
			R_OWNER,
			R_CONSTRAINT_NAME,
			DELETE_RULE
		FROM SYS.ALL_CONSTRAINTS
		WHERE OWNER = '%s'
		ORDER BY TABLE_NAME, CONSTRAINT_NAME`, schemaName)

	slog.Debug("running get constraints query")
	constraintRows, err := txn.Query(queryConstraints)
	if err != nil {
		return nil, nil, nil, nil, util.FormatErrorWithQuery(err, queryConstraints)
	}