diff --git a/sqlx.go b/sqlx.go index 8259a4feb..95f4669c4 100644 --- a/sqlx.go +++ b/sqlx.go @@ -136,6 +136,10 @@ func isUnsafe(i interface{}) bool { return v.unsafe case *Tx: return v.unsafe + case Conn: + return v.unsafe + case *Conn: + return v.unsafe case sql.Rows, *sql.Rows: return false default: @@ -153,6 +157,10 @@ func mapperFor(i interface{}) *reflectx.Mapper { return i.Mapper case *Tx: return i.Mapper + case Conn: + return i.Mapper + case *Conn: + return i.Mapper default: return mapper() }