当缓存为空时，我如何进行数据库调用，并将值从数据库设置到缓存中？

huangapple
go评论100阅读模式
英文:

how do I make a db call when cache is empty and set value to cache from db?

问题

以下是您提供的内容的翻译部分：

我有一个缓存和一个数据库。我正在从缓存中获取值。如果缓存中的数据为空（因为已过期），我会从数据库中获取数据，并在从缓存中获取数据后，将值从数据库设置到缓存中。

  1. Single<String> get() {
  2.     return getFromCache().onErrorResumeNext(getFromDatabase());
  3. }
  5. Single<String> getFromCache()  {
  6.     //return Single.just("cache");
  7.     return Single.error(new Exception("exception"));
  8. }
  10. Single<String> getFromDatabase() {
  11.     return Single.just("database");
  12. }
  14. Single<String> setDatabase(Single<String> val) {
  15.     return val.map(
  16.             v -> {
  17.                 String res = v;
  18.                 System.out.println(res);
  19.                 return res;
  20.             }
  21.     );
  22. }

在这里，如果从缓存中获取的值为空，我可以调用数据库，但是接下来我无法调用 setDatabase 方法。

------------ 我已经找到了解决方法 ---------------------------

由于我对 RxJava 不太了解，我想知道最佳解决方法是什么。

  1. Single<String> get() {
  2.     Observable<String> cacheObservable = getFromCache().toObservable();
  3.     Observable<String> databaseObservable = getFromDatabase().toObservable();
  5.     Single<String> result = Observable.concat(cacheObservable, databaseObservable).firstOrError();
  7.     databaseObservable.doOnNext(val -> {
  8.         setDatabase(val);
  9.     });
  10.     return result;
  11. }
  13. Maybe<String> getFromCache()  {
  14.    //return Maybe.just("cache");
  15.    return Maybe.empty();
  16. }
  18. Single<String> getFromDatabase() {
  19.     return Single.just("database");
  20. }
  22. void setDatabase(String res) {
  23.     System.out.println(res);
  24. }

请注意，我只翻译了您提供的代码部分，其他部分均被忽略。如果您有任何进一步的问题或需要更多的帮助，请随时提问。

英文:

I have a cache and a database.I am fetching value from cache. if data from cache is empty (due to expiration). I am making a call to database and after fetching data from cache. I will set the value from database to cache.

  1. Single&lt;String&gt; get() {
  2.     return getFromCache().onErrorResumeNext(getFromDatabase());
  3. }
  5. Single&lt;String&gt; getFromCache()  { // or should I use may be here
  6.    //return Single.just(&quot;cache&quot;);
  7.     return Single.error(new Exception(&quot;exception&quot;));
  8. }
  10. Single&lt;String&gt; getFromDatabase() {
  11.     return Single.just(&quot;database&quot;);
  12. }
  14. Single&lt;String&gt; setDatabase(Single&lt;String&gt; val) {
  15.     return val.map(
  16.             v -&gt; {
  17.                 String res = v;
  18.                 System.out.println(res);
  19.                 return res;
  20.             }
  21.     );
  22. }

Here I am able to call database if value from cache is empty but then I am not able to call method setDatabase.

------------ I have found this way to solve it---------------------------
Since I am new to rxjava. I wanted to what is best way to solve this

  1. Single&lt;String&gt; get() {
  2.     Observable&lt;String&gt; cacheObservable = getFromCache().toObservable();
  3.     Observable&lt;String&gt; databaseObservable = getFromDatabase().toObservable();
  5.     Single&lt;String&gt; result = Observable.concat(cacheObservable, databaseObservable).firstOrError();
  7.     databaseObservable.doOnNext(val-&gt; {
  8.         setDatabase(val);
  9.     });
  10.     return result;
  11. }
  13. Maybe&lt;String&gt; getFromCache()  { // or should I use may be here
  14.    //return Maybe.just(&quot;cache&quot;);
  15.    return Maybe.empty();
  16. }
  18. Single&lt;String&gt; getFromDatabase() {
  19.     return Single.just(&quot;database&quot;);
  20. }
  22. void setDatabase(String res) {
  23.     System.out.println(res);
  24. }

答案1

得分: 0

你几乎完成了，针对你的用例使用switchIfEmpty：

  1. Single<String> get() {
  2.     return getFromCache()
  3.             .switchIfEmpty(getFromDatabase().doOnSuccess(this::setDatabase));
  4. }
英文:

You were almost done, use switchIfEmpty for your use case :

  1. Single&lt;String&gt; get() {
  2.         return getFromCache()
  3.                 .switchIfEmpty(getFromDatabase().doOnSuccess(this::setDatabase));
  4.     }

huangapple
  • 本文由 发表于 2020年10月26日 16:04:34
  • 转载请务必保留本文链接：https://go.coder-hub.com/64533379.html
  • caching
  • java
  • rx-java
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定