ServerDao.java 836 Bytes
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
package chat.rocket.android.server.infraestructure;

import android.arch.persistence.room.Dao;
import android.arch.persistence.room.Delete;
import android.arch.persistence.room.Insert;
import android.arch.persistence.room.OnConflictStrategy;
import android.arch.persistence.room.Query;
import android.arch.persistence.room.Update;

import java.util.List;

import io.reactivex.Single;

@Dao
public interface ServerDao {
    @Insert(onConflict = OnConflictStrategy.FAIL)
    void insertServer(ServerEntity serverEntity);

    @Update
    void updateServer(ServerEntity serverEntity);

    @Delete
    void deleteServer(ServerEntity serverEntity);

    @Query("SELECT * FROM server")
    Single<List<ServerEntity>> getServers();

    @Query("SELECT * FROM server WHERE id = :serverId")
    Single<ServerEntity> getServer(Long serverId);
}