AppDataSource.java

@BindDataSource(fileName="app.db", version=1, daoSet={DaoPerson.class})
public interface AppDataSource {
	
	/**
	 * @param daoPerson
	 * 		is injected by kripton
	 * @param name
	 * 		is 
	 */
	@BindTransaction
	static void execute(DaoPerson daoPerson, String name) {
		daoPerson.insert(new Person(-1, name, "Surname"));		
	}
}

Usage.java

@Test
	public void testSelect() throws InterruptedException, ExecutionException {
		BindAppDataSource ds = BindAppDataSource.getInstance();
		Future<Boolean> result = ds.executeAsync("tonj");
		
		log("Result : "+result.get());
		 
		List<Person> list = ds.executeBatch(daoFactory -> {
			return daoFactory.getDaoPerson().select("tonj");
		});
		
		assertEquals(1, list.size());
		
		Thread.sleep(1000);

	}