Index: PGResultRow.m ================================================================== --- PGResultRow.m +++ PGResultRow.m @@ -44,11 +44,17 @@ [super dealloc]; } - (size_t)count { - return PQnfields(res); + size_t i, count, fields = PQnfields(res); + + for (i = count = 0; i < fields; i++) + if (!PQgetisnull(res, row, i)) + count++; + + return count; } - (id)objectForKey: (id)key { int col; @@ -55,10 +61,13 @@ if ([key isKindOfClass: [OFNumber class]]) col = [key intValue]; else col = PQfnumber(res, [key UTF8String]); + + if (PQgetisnull(res, row, col)) + return nil; return [OFString stringWithUTF8String: PQgetvalue(res, row, col)]; } - (OFEnumerator*)keyEnumerator @@ -99,19 +108,31 @@ @implementation PGResultRowKeyEnumerator - (id)nextObject { if (pos >= count) return nil; + + while (pos < count && PQgetisnull(res, row, pos)) + pos++; + + if (pos >= count) + return nil; return [OFString stringWithUTF8String: PQfname(res, pos++)]; } @end @implementation PGResultRowObjectEnumerator - (id)nextObject { + if (pos >= count) + return nil; + + while (pos < count && PQgetisnull(res, row, pos)) + pos++; + if (pos >= count) return nil; return [OFString stringWithUTF8String: PQgetvalue(res, row, pos++)]; } @end Index: test.m ================================================================== --- test.m +++ test.m @@ -29,16 +29,16 @@ @" content text" @")"]; [connection executeCommand: @"INSERT INTO test (id, name, content) " @"VALUES($1, $2, $3)" parameters: @[@"1", @"foo", @"Hallo Welt!"]]; - [connection executeCommand: @"INSERT INTO test (id, name, content) " - @"VALUES($1, $2, $3)" - parameters: @[@"2", @"bla", @"Blup!!"]]; + [connection executeCommand: @"INSERT INTO test (id, content) " + @"VALUES($1, $2)" + parameters: @[@"2", @"Blup!!"]]; result = [connection executeCommand: @"SELECT * FROM test"]; of_log(@"%@", result); of_log(@"JSON: %@", [result JSONRepresentation]); [OFApplication terminate]; } @end