pg库，如果oid索引，会导致判断出错 #2103

New Issue

4color · 2022-01-19T07:17:08Z

4color commented

2022-01-19 07:17:08 +00:00

postgres.go GetIndexes 方法

func (db *postgres) GetIndexes(queryer core.Queryer, ctx context.Context, tableName string) (map[string]*schemas.Index, error) {
	args := []interface{}{tableName}
	s := "SELECT indexname, indexdef FROM pg_indexes WHERE tablename=$1"
	if len(db.getSchema()) != 0 {
		args = append(args, db.getSchema())
		s = s + " AND schemaname=$2"
	}

	rows, err := queryer.QueryContext(ctx, s, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

    
    //这里得到的字段名是 oid 
    colNames = getIndexColName(indexdef)

再回到  engin.go loadTableInfo 这个中，判断列是否有这个索引名，就会出错

   if col := table.GetColumn(colName); col != nil {
col.Indexes[index.Name] = index.Type
} else {
return fmt.Errorf("Unknown col %s seq %d, in index %v of table %v, columns %v", name, seq, index.Name, table.Name, table.ColumnsSeq())
}

![image](/attachments/5dc8e120-85ef-4121-8bc2-5990d197f67b) postgres.go GetIndexes 方法 ``` func (db *postgres) GetIndexes(queryer core.Queryer, ctx context.Context, tableName string) (map[string]*schemas.Index, error) { args := []interface{}{tableName} s := "SELECT indexname, indexdef FROM pg_indexes WHERE tablename=$1" if len(db.getSchema()) != 0 { args = append(args, db.getSchema()) s = s + " AND schemaname=$2" } rows, err := queryer.QueryContext(ctx, s, args...) if err != nil { return nil, err } defer rows.Close() ``` ``` //这里得到的字段名是 oid colNames = getIndexColName(indexdef) ``` 再回到 engin.go loadTableInfo 这个中，判断列是否有这个索引名，就会出错 ``` if col := table.GetColumn(colName); col != nil { col.Indexes[index.Name] = index.Type } else { return fmt.Errorf("Unknown col %s seq %d, in index %v of table %v, columns %v", name, seq, index.Name, table.Name, table.ColumnsSeq()) } ```

image.png

24 KiB

image.png

17 KiB