Argthtjtr

I am trying to fetch some data from API and save it to room database, but the idea I have a column and I am changing its value "isFavourite".

I saw in some answers about this to use upsert function, and I tried to use it but still overriding data everytime.

@Dao

public abstract class ChannelDao {



@Insert(onConflict = OnConflictStrategy.IGNORE)

abstract long addChannelData(Channel channel);



@Query("UPDATE channel_table SET name= :name, url= :url , icon= :icon , streamer= :streamer , package_id= :package_id WHERE number= :number")

abstract void updateChannelData(String number, String name, String url, String icon, String streamer, String package_id);



@Transaction

void insOrUpdate(Channel channel) {

   long id = addChannelData(channel);

    if (id == -1) {

     updateChannelData(channel.getNumber(), channel.getName(), channel.getUrl(), channel.getIcon(), channel.getStreamer(), channel.getPackage_id());

}

}





@Entity(tableName = "channel_table", foreignKeys = @ForeignKey(entity = ChannelsPackage.class, parentColumns = "id", childColumns = "package_id", onDelete = CASCADE))



public class Channel {



@NonNull

@PrimaryKey

@SerializedName("number")

@Expose

private String number;

@SerializedName("name")

@Expose

private String name;

@SerializedName("url")

@Expose

private String url;

@SerializedName("icon")

@Expose

private String icon;

@SerializedName("streamer")

@Expose

private String streamer;



private boolean favorite;



private boolean locked;



private String package_id;



public Channel(@NonNull String number, String name, String url, String icon, String streamer, boolean favorite, boolean locked, String package_id) {

    this.number = number;

    this.name = name;

    this.url = url;

    this.icon = icon;

    this.streamer = streamer;

    this.favorite = favorite;

    this.locked = locked;

    this.package_id = package_id;

}

@NonNull

public String getNumber() {

    return number;

}



public void setNumber(@NonNull String number) {

    this.number = number;

}



public String getName() {

    return name;

}



public void setName(String name) {

    this.name = name;

}



public String getUrl() {

    return url;

}



public void setUrl(String url) {

    this.url = url;

}



public String getIcon() {

    return icon;

}



public void setIcon(String icon) {

    this.icon = icon;

}



public String getStreamer() {

    return streamer;

}



public void setStreamer(String streamer) {

    this.streamer = streamer;

}



public boolean isFavorite() {

    return favorite;

}



public void setFavorite(boolean favorite) {

    this.favorite = favorite;

}



public boolean isLocked() {

    return locked;

}



public void setLocked(boolean locked) {

    this.locked = locked;

}



public String getPackage_id() {

    return package_id;

}



public void setPackage_id(String package_id) {

    this.package_id = package_id;

}

}

Change to onConflictStrategy.ABORT. This way it will abort the transaction.

After a search and search for 4 days, found the issue,
I have 2 tables channel_table and package_table

and the relation between them was one too many, and I was adding the packages every time before the channels and the was "onDelete = CASCADE"
so that's why all channels were deleted every time I am trying to update.

and for info to make upsert method it will be like this:

@Insert(onConflict = OnConflictStrategy.REPLACE)

    abstract void addChannelData(Channel channel);



 @Query("UPDATE channel_table SET name= :name, url= :url , icon= :icon , streamer= :streamer , package_id= :package_id WHERE number= :number")

    abstract void updateChannelData(String number, String name, String url, String icon, String streamer, String package_id);



@Transaction

    @Query("SELECT COUNT(*) from channel_table WHERE number = :number")

    abstract int isChannelExist(String number);



    @Transaction

    void insOrUpdate(List<Channel> channels) {

        for (Channel channel : channels) {

            if (isChannelExist(channel.getNumber()) > 0) {

                updateChannelData(channel.getNumber(), channel.getName(), channel.getUrl(), channel.getIcon(), channel.getStreamer(), channel.getPackage_id());

            } else {

                addChannelData(channel);

            }

        }



    }