@@ -88,20 +88,21 @@ public void loadAllHelper( List<T> l, String query, FieldList fields, RSExtracto
88
88
try {
89
89
long startTime = System .currentTimeMillis ();
90
90
String queryId = this .createQueryId (startTime );
91
- log .debug ( "queryId:{}, loadAll START list : '{}' " , queryId , l .size () );
92
- log .debug ( "queryId:{}, loadAll fields : '{}'" , queryId , fields .size () );
93
- log .debug ( "queryId:{}, loadAll RSExtractor : '{}'" , queryId , re );
91
+ log .debug ( "queryId:'{}', loadAll START list : '{}'" , queryId , l .size () );
92
+ log .debug ( "queryId:'{}', loadAll sql : '{}'" , queryId , query );
93
+ log .debug ( "queryId:'{}', loadAll fields : '{}'" , queryId , fields .size () );
94
+ log .debug ( "queryId:'{}', loadAll RSExtractor : '{}'" , queryId , re );
94
95
Connection conn = this .daoContext .getConnection ();
95
96
int i =0 ;
96
97
try ( PreparedStatement ps = conn .prepareStatement ( query ) ) {
97
- DAOHelper .setAll ( ps , fields , this );
98
+ DAOHelper .setAll ( queryId , ps , fields , log );
98
99
try ( ResultSet rs = ps .executeQuery () ) {
99
- log .debug ("queryId:{} , loadAll query execute end time : '{}'" , queryId , CheckpointUtils .formatTimeDiff (startTime , System .currentTimeMillis ()) );
100
+ log .debug ("queryId:'{}' , loadAll query execute end time : '{}'" , queryId , CheckpointUtils .formatTimeDiff (startTime , System .currentTimeMillis ()) );
100
101
while (rs .next ()) {
101
102
l .add ( re .extractNext ( rs ) );
102
103
i ++;
103
104
}
104
- log .debug ("queryId:{} , loadAll query result end time : '{}'" , queryId , CheckpointUtils .formatTimeDiff (startTime , System .currentTimeMillis ()) );
105
+ log .debug ("queryId:'{}' , loadAll query result end time : '{}'" , queryId , CheckpointUtils .formatTimeDiff (startTime , System .currentTimeMillis ()) );
105
106
}
106
107
} catch (SQLException e ) {
107
108
throw (new DAOException ( e .getMessage ()+"[query:" +query +",record:" +i +"]" , e ));
0 commit comments