@@ -76,7 +76,10 @@ Object getValue() throws SQLException
7676protected java .sql .PreparedStatement deleteStatement =null ;
7777
7878
79- private java .sql .Statement currentStatement =null ;
79+ /**
80+ * PreparedStatement used to refresh data
81+ */
82+ private java .sql .PreparedStatement selectStatement =null ;
8083
8184
8285/**
@@ -617,6 +620,78 @@ public synchronized void updateObject(int columnIndex, Object x, int scale) thro
617620
618621}
619622
623+
624+ public void refreshRow ()throws SQLException
625+ {
626+ if ( !isUpdateable () )
627+ {
628+ throw new PSQLException ("postgresql.updateable.notupdateable" );
629+ }
630+
631+ try
632+ {
633+ StringBuffer selectSQL =new StringBuffer ("select " );
634+
635+ final int numColumns =java .lang .reflect .Array .getLength (fields );
636+
637+ for (int i =0 ;i <numColumns ;i ++ )
638+ {
639+
640+ selectSQL .append (fields [i ].getName () );
641+
642+ if (i <numColumns -1 )
643+ {
644+
645+ selectSQL .append (", " );
646+ }
647+
648+ }
649+ selectSQL .append (" from " ).append (tableName ).append (" where " );
650+
651+ int numKeys =primaryKeys .size ();
652+
653+ for (int i =0 ;i <numKeys ;i ++ )
654+ {
655+
656+ PrimaryKey primaryKey = ((PrimaryKey )primaryKeys .get (i ));
657+ selectSQL .append (primaryKey .name ).append ("= ?" );
658+
659+ if (i <numKeys -1 )
660+ {
661+ selectSQL .append (" and " );
662+ }
663+ }
664+ if (Driver .logDebug )Driver .debug ("selecting " +selectSQL .toString ());
665+ selectStatement = ((java .sql .Connection )connection ).prepareStatement (selectSQL .toString ());
666+
667+
668+ for (int j =0 ,i =1 ;j <numKeys ;j ++,i ++)
669+ {
670+ selectStatement .setObject (i , ((PrimaryKey )primaryKeys .get (j )).getValue () );
671+ }
672+
673+ org .postgresql .jdbc2 .ResultSet rs = (org .postgresql .jdbc2 .ResultSet )selectStatement .executeQuery ();
674+
675+ if (rs .first () )
676+ {
677+ rowBuffer =rs .rowBuffer ;
678+ }
679+
680+ rows .setElementAt (rowBuffer ,current_row );
681+ if (Driver .logDebug )Driver .debug ("done updates" );
682+
683+ rs .close ();
684+ selectStatement .close ();
685+ selectStatement =null ;
686+
687+ }
688+ catch (Exception e )
689+ {
690+ if (Driver .logDebug )Driver .debug (e .getClass ().getName ()+e );
691+ throw new SQLException (e .getMessage () );
692+ }
693+
694+ }
620695/**
621696 *
622697 * @throws SQLException
