@ -81,32 +81,32 @@ class AggregateChangeExecutor {
private void execute ( DbAction < ? > action , JdbcAggregateChangeExecutionContext executionContext ) {
private void execute ( DbAction < ? > action , JdbcAggregateChangeExecutionContext executionContext ) {
try {
try {
if ( action instanceof DbAction . InsertRoot ) {
if ( action instanceof DbAction . InsertRoot < ? > insertRoot ) {
executionContext . executeInsertRoot ( ( DbAct ion . I nsertRoot< ? > ) action ) ;
executionContext . executeInsertRoot ( insertRoot ) ;
} else if ( action instanceof DbAction . BatchInsertRoot < ? > ) {
} else if ( action instanceof DbAction . BatchInsertRoot < ? > batchInsertRoot ) {
executionContext . executeBatchInsertRoot ( ( D bAction . B atchInsertRoot< ? > ) action ) ;
executionContext . executeBatchInsertRoot ( batchInsertRoot ) ;
} else if ( action instanceof DbAction . Insert ) {
} else if ( action instanceof DbAction . Insert < ? > insert ) {
executionContext . executeInsert ( ( DbAct ion . I nsert< ? > ) action ) ;
executionContext . executeInsert ( insert ) ;
} else if ( action instanceof DbAction . BatchInsert ) {
} else if ( action instanceof DbAction . BatchInsert < ? > batchInsert ) {
executionContext . executeBatchInsert ( ( D bAction . B atchInsert< ? > ) action ) ;
executionContext . executeBatchInsert ( batchInsert ) ;
} else if ( action instanceof DbAction . UpdateRoot ) {
} else if ( action instanceof DbAction . UpdateRoot < ? > updateRoot ) {
executionContext . executeUpdateRoot ( ( DbAction . UpdateRoot < ? > ) action ) ;
executionContext . executeUpdateRoot ( updateRoot ) ;
} else if ( action instanceof DbAction . Delete ) {
} else if ( action instanceof DbAction . Delete < ? > delete ) {
executionContext . executeDelete ( ( DbAction . Delete < ? > ) action ) ;
executionContext . executeDelete ( delete ) ;
} else if ( action instanceof DbAction . BatchDelete < ? > ) {
} else if ( action instanceof DbAction . BatchDelete < ? > batchDelete ) {
executionContext . executeBatchDelete ( ( D bAction . B atchDelete< ? > ) action ) ;
executionContext . executeBatchDelete ( batchDelete ) ;
} else if ( action instanceof DbAction . DeleteAll ) {
} else if ( action instanceof DbAction . DeleteAll < ? > deleteAll ) {
executionContext . executeDeleteAll ( ( DbAction . DeleteAll < ? > ) action ) ;
executionContext . executeDeleteAll ( deleteAll ) ;
} else if ( action instanceof DbAction . DeleteRoot ) {
} else if ( action instanceof DbAction . DeleteRoot < ? > deleteRoot ) {
executionContext . executeDeleteRoot ( ( DbAction . DeleteRoot < ? > ) action ) ;
executionContext . executeDeleteRoot ( deleteRoot ) ;
} else if ( action instanceof DbAction . BatchDeleteRoot ) {
} else if ( action instanceof DbAction . BatchDeleteRoot < ? > batchDeleteRoot ) {
executionContext . executeBatchDeleteRoot ( ( D bAction . B atchDeleteRoot< ? > ) action ) ;
executionContext . executeBatchDeleteRoot ( batchDeleteRoot ) ;
} else if ( action instanceof DbAction . DeleteAllRoot ) {
} else if ( action instanceof DbAction . DeleteAllRoot < ? > deleteAllRoot ) {
executionContext . executeDeleteAllRoot ( ( DbAction . DeleteAllRoot < ? > ) action ) ;
executionContext . executeDeleteAllRoot ( deleteAllRoot ) ;
} else if ( action instanceof DbAction . AcquireLockRoot ) {
} else if ( action instanceof DbAction . AcquireLockRoot < ? > acquireLockRoot ) {
executionContext . executeAcquireLock ( ( DbAction . A cquireLockRoot< ? > ) action ) ;
executionContext . executeAcquireLock ( a cquireLockRoot) ;
} else if ( action instanceof DbAction . AcquireLockAllRoot ) {
} else if ( action instanceof DbAction . AcquireLockAllRoot < ? > acquireLockAllRoot ) {
executionContext . executeAcquireLockAllRoot ( ( DbAction . A cquireLockAllRoot< ? > ) action ) ;
executionContext . executeAcquireLockAllRoot ( a cquireLockAllRoot) ;
} else {
} else {
throw new RuntimeException ( "unexpected action" ) ;
throw new RuntimeException ( "unexpected action" ) ;
}
}