DaoPerson.java

@BindDao(Person.class)
public interface DaoPerson {

	@BindSqlSelect(where = "name like ${name} || '%'")
	PagedLiveData<List<Person>> selectPaged(String name);

	@BindSqlInsert
	void insert(Person bean);

	@BindSqlUpdate(where = "id=${bean.id}")
	void update(Person bean);

}

Usage.java

@Test
	public void testRun() throws InterruptedException {
		BindAppDataSource ds = BindAppDataSource.getInstance();

		final PagedLiveData<List<Person>> liveData = ds.getDaoPerson().selectPaged("Manero");
		liveData.observeForever(t -> {
			log("--> Page %s -- size %s", liveData.getPage(), t.size());
		});

		ds.execute(daoFactory -> {
			for (int i = 0; i < 100; i++) {
				Person person = new Person();
				person.name = "Manero" + i;
				person.surname = "Tonj" + i;
				daoFactory.getDaoPerson().insert(person);
			}
			return TransactionResult.COMMIT;
		});

		liveData.nextPage();

		ds.execute(daoFactory -> {
			Person person = new Person();
			person.name = "Manero";
			person.surname = "Tonj";
			daoFactory.getDaoPerson().insert(person);
			return TransactionResult.COMMIT;
		});

		liveData.createPageRequestBuilder().pageSize(41).offset(11).apply();
		liveData.setOffset(liveData.getOffset() + 100);

		liveData.setPage(1);
		liveData.nextPage();
		liveData.previousPage();
		liveData.nextPage();

		Thread.sleep(1000);

	}