@@ -911,42 +911,42 @@ private void save() {
911
911
if (JdbcSession .this .changed ) {
912
912
deltaActions .add (() -> {
913
913
Map <String , String > indexes = JdbcIndexedSessionRepository .this .indexResolver
914
- .resolveIndexesFor (JdbcSession .this );
914
+ .resolveIndexesFor (JdbcSession .this );
915
915
JdbcIndexedSessionRepository .this .jdbcOperations
916
- .update (JdbcIndexedSessionRepository .this .updateSessionQuery , (ps ) -> {
917
- ps .setString (1 , getId ());
918
- ps .setLong (2 , getLastAccessedTime ().toEpochMilli ());
919
- ps .setInt (3 , (int ) getMaxInactiveInterval ().getSeconds ());
920
- ps .setLong (4 , getExpiryTime ().toEpochMilli ());
921
- ps .setString (5 , indexes .get (PRINCIPAL_NAME_INDEX_NAME ));
922
- ps .setString (6 , JdbcSession .this .primaryKey );
923
- });
916
+ .update (JdbcIndexedSessionRepository .this .updateSessionQuery , (ps ) -> {
917
+ ps .setString (1 , getId ());
918
+ ps .setLong (2 , getLastAccessedTime ().toEpochMilli ());
919
+ ps .setInt (3 , (int ) getMaxInactiveInterval ().getSeconds ());
920
+ ps .setLong (4 , getExpiryTime ().toEpochMilli ());
921
+ ps .setString (5 , indexes .get (PRINCIPAL_NAME_INDEX_NAME ));
922
+ ps .setString (6 , JdbcSession .this .primaryKey );
923
+ });
924
924
});
925
925
}
926
926
927
927
List <String > addedAttributeNames = JdbcSession .this .delta .entrySet ()
928
- .stream ()
929
- .filter ((entry ) -> entry .getValue () == DeltaValue .ADDED )
930
- .map (Map .Entry ::getKey )
931
- .collect (Collectors .toList ());
928
+ .stream ()
929
+ .filter ((entry ) -> entry .getValue () == DeltaValue .ADDED )
930
+ .map (Map .Entry ::getKey )
931
+ .collect (Collectors .toList ());
932
932
if (!addedAttributeNames .isEmpty ()) {
933
933
deltaActions .add (() -> insertSessionAttributes (JdbcSession .this , addedAttributeNames ));
934
934
}
935
935
936
936
List <String > updatedAttributeNames = JdbcSession .this .delta .entrySet ()
937
- .stream ()
938
- .filter ((entry ) -> entry .getValue () == DeltaValue .UPDATED )
939
- .map (Map .Entry ::getKey )
940
- .collect (Collectors .toList ());
937
+ .stream ()
938
+ .filter ((entry ) -> entry .getValue () == DeltaValue .UPDATED )
939
+ .map (Map .Entry ::getKey )
940
+ .collect (Collectors .toList ());
941
941
if (!updatedAttributeNames .isEmpty ()) {
942
942
deltaActions .add (() -> updateSessionAttributes (JdbcSession .this , updatedAttributeNames ));
943
943
}
944
944
945
945
List <String > removedAttributeNames = JdbcSession .this .delta .entrySet ()
946
- .stream ()
947
- .filter ((entry ) -> entry .getValue () == DeltaValue .REMOVED )
948
- .map (Map .Entry ::getKey )
949
- .collect (Collectors .toList ());
946
+ .stream ()
947
+ .filter ((entry ) -> entry .getValue () == DeltaValue .REMOVED )
948
+ .map (Map .Entry ::getKey )
949
+ .collect (Collectors .toList ());
950
950
if (!removedAttributeNames .isEmpty ()) {
951
951
deltaActions .add (() -> deleteSessionAttributes (JdbcSession .this , removedAttributeNames ));
952
952
}
0 commit comments