package com.dayu.pipirrapp.dao;

import androidx.room.Dao;
import androidx.room.Delete;
import androidx.room.Insert;
import androidx.room.OnConflictStrategy;
import androidx.room.Query;
import androidx.room.Update;

import com.dayu.pipirrapp.bean.db.MarkerBean;

import java.util.List;

import io.reactivex.rxjava3.core.Completable;
import io.reactivex.rxjava3.core.Single;
import io.reactivex.rxjava3.core.Maybe;

/**
 * author: zuo
 * Date: 2024-09-30
 * Time: 14:39
 * 备注：取水口
 */
@Dao
public interface MarkerDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    void insert(MarkerBean markerBean);

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    Completable insertAll(List<MarkerBean> markerBeans); // 使用 Completable 进行异步插入

//    @Insert(onConflict = OnConflictStrategy.REPLACE)
//    void insertAll(List<MarkerBean> markerBeans); // 使用 Completable 进行异步插入

    @Update
    void update(MarkerBean markerBean);

    @Delete
    void delete(MarkerBean markerBean);

    @Query("DELETE FROM MarkerBean")
    void deleteAll();

    @Query("select  * from MarkerBean limit 1")
    MarkerBean findFirst();

    @Query("select  * from MarkerBean")
    List<MarkerBean> findAll();

    @Query("select  * from MarkerBean")
    Single<List<MarkerBean>> findAllToSingle();

    @Query("SELECT * FROM MarkerBean")
    Maybe<List<MarkerBean>> getAll();

    @Query("SELECT * FROM MarkerBean WHERE name LIKE '%' || :name || '%'")
    Single<List<MarkerBean>> findByNameLike(String name);

    @Query("UPDATE MarkerBean SET lng = :lng, lat = :lat WHERE id = :id")
    Completable updateMarkerLocation(String id, String lng, String lat);
}