import net.floodlightcontroller.storage.IStorageSourceListener; //导入依赖的package包/类
@Test
public void testInsertNotification() {
    // Set up the listener and record the expected notification
    IStorageSourceListener mockListener = createNiceMock(IStorageSourceListener.class);
    Set<Object> expectedKeys = new HashSet<Object>();
    expectedKeys.add("999-99-9999");
    mockListener.rowsModified(PERSON_TABLE_NAME, expectedKeys);
    
    replay(mockListener);

    // Now try it for real
    storageSource.addListener(PERSON_TABLE_NAME, mockListener);

    // Create a new person, which should trigger the listener
    Object[] newPerson = {"999-99-9999", "Serena", "Williams", 22, true};
    insertPerson(newPerson);
    
    verify(mockListener);
}
 

import net.floodlightcontroller.storage.IStorageSourceListener; //导入依赖的package包/类
@Test
public void testUpdateNotification() {
    // Set up the listener and record the expected notification
    IStorageSourceListener mockListener = createNiceMock(IStorageSourceListener.class);
    Set<Object> expectedKeys = new HashSet<Object>();
    expectedKeys.add("111-11-1111");
    mockListener.rowsModified(PERSON_TABLE_NAME, expectedKeys);
    
    replay(mockListener);

    // Now try it for real
    storageSource.addListener(PERSON_TABLE_NAME, mockListener);

    // Create a new person, which should trigger the listener
    Map<String,Object> updateValues = new HashMap<String,Object>();
    updateValues.put(PERSON_FIRST_NAME, "Tennis");
    storageSource.updateRow(PERSON_TABLE_NAME, "111-11-1111", updateValues);
    
    verify(mockListener);
}
 

import net.floodlightcontroller.storage.IStorageSourceListener; //导入依赖的package包/类
@Test
public void testDeleteNotification() {
    IStorageSourceListener mockListener = createNiceMock(IStorageSourceListener.class);
    Set<Object> expectedKeys = new HashSet<Object>();
    expectedKeys.add("111-11-1111");
    mockListener.rowsDeleted(PERSON_TABLE_NAME, expectedKeys);
    
    replay(mockListener);

    // Now try it for real
    storageSource.addListener(PERSON_TABLE_NAME, mockListener);

    // Create a new person, which should trigger the listener
    storageSource.deleteRow(PERSON_TABLE_NAME, "111-11-1111");
    
    verify(mockListener);
}