Use more detailed error output of unknown field;
This commit is contained in:
@@ -1133,7 +1133,8 @@ func (c *Conn) prepareEx(name, sql string, opts *PrepareExOptions) (ps *Prepared
|
|||||||
ps.FieldDescriptions[i].FormatCode = TextFormatCode
|
ps.FieldDescriptions[i].FormatCode = TextFormatCode
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
return nil, errors.Errorf("unknown oid: %d", ps.FieldDescriptions[i].DataType)
|
fd := ps.FieldDescriptions[i]
|
||||||
|
return nil, errors.Errorf("unknown oid: %d, name: %s", fd.DataType, fd.Name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
case *pgproto3.ReadyForQuery:
|
case *pgproto3.ReadyForQuery:
|
||||||
|
|||||||
@@ -137,7 +137,8 @@ func (rows *Rows) Next() bool {
|
|||||||
rows.fields[i].DataTypeName = dt.Name
|
rows.fields[i].DataTypeName = dt.Name
|
||||||
rows.fields[i].FormatCode = TextFormatCode
|
rows.fields[i].FormatCode = TextFormatCode
|
||||||
} else {
|
} else {
|
||||||
rows.fatal(errors.Errorf("unknown oid: %d", rows.fields[i].DataType))
|
fd := rows.fields[i]
|
||||||
|
rows.fatal(errors.Errorf("unknown oid: %d, name: %s", fd.DataType, fd.Name))
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -259,7 +260,7 @@ func (rows *Rows) Scan(dest ...interface{}) (err error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
rows.fatal(scanArgError{col: i, err: errors.Errorf("unknown oid: %v", fd.DataType)})
|
rows.fatal(scanArgError{col: i, err: errors.Errorf("unknown oid: %v, name: %s", fd.DataType, fd.Name)})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -507,7 +508,8 @@ func (c *Conn) readUntilRowDescription() ([]FieldDescription, error) {
|
|||||||
if dt, ok := c.ConnInfo.DataTypeForOID(fieldDescriptions[i].DataType); ok {
|
if dt, ok := c.ConnInfo.DataTypeForOID(fieldDescriptions[i].DataType); ok {
|
||||||
fieldDescriptions[i].DataTypeName = dt.Name
|
fieldDescriptions[i].DataTypeName = dt.Name
|
||||||
} else {
|
} else {
|
||||||
return nil, errors.Errorf("unknown oid: %d", fieldDescriptions[i].DataType)
|
fd := fieldDescriptions[i]
|
||||||
|
return nil, errors.Errorf("unknown oid: %d, name: %s", fd.DataType, fd.Name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return fieldDescriptions, nil
|
return fieldDescriptions, nil
|
||||||
|
|||||||
Reference in New Issue
Block a user