125. (TWOK/UTIL) [Android/Java] C_FirebaseRealDatabase : 파이어베이스 RealDatabase 관리 클래스

---

[설 명]

​

프로그램 : Android / Java

​

설 명 : C_FirebaseRealDatabase : 파이어베이스 RealDatabase 관리 클래스

 

---

[소스 코드]

 

package com.example.javaproject.C_Firebase;

import android.app.Activity;
import android.content.Context;
import android.net.Uri;

import com.example.javaproject.C_Permission;
import com.example.javaproject.C_Util;
import com.example.javaproject.S_Log;
import com.google.android.gms.tasks.OnCompleteListener;
import com.google.android.gms.tasks.OnFailureListener;
import com.google.android.gms.tasks.OnSuccessListener;
import com.google.android.gms.tasks.Task;
import com.google.firebase.database.DataSnapshot;
import com.google.firebase.database.DatabaseReference;
import com.google.firebase.database.FirebaseDatabase;
import com.google.firebase.remoteconfig.FirebaseRemoteConfig;
import com.google.firebase.remoteconfig.FirebaseRemoteConfigSettings;
import com.google.firebase.storage.FirebaseStorage;
import com.google.firebase.storage.ListResult;
import com.google.firebase.storage.StorageReference;
import com.google.firebase.storage.UploadTask;

import java.io.File;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;

import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.Observable;

public class C_FirebaseRealDatabase {


    /**
     * // --------------------------------------------------------------------------------------
     * TODO [클래스 설명]
     * // --------------------------------------------------------------------------------------
     * 1. 파이어베이스 RealDatabase 관리 클래스
     * // --------------------------------------------------------------------------------------
     * 2. 참고 사이트 (기본 설명) : https://firebase.google.com/docs/database?hl=ko
     * // --------------------------------------------------------------------------------------
     * 3. 참고 사이트 (비용 설명) : https://firebase.google.com/pricing?hl=ko
     * // --------------------------------------------------------------------------------------
     * 4. 참고 사이트 (생성 방법) : https://blog.naver.com/kkh0977/223378984217
     * // --------------------------------------------------------------------------------------
     * 5. TODO 서비스 적용 방법 :
     *
     *   - 안드로이드에서 사전 파일 외부 저장소 접근 파일 읽기, 쓰기 권한 필요
     *   - 파이베이스 콘솔 프로젝트 생성
     *   - googole.json 파일 프로젝트에 추가
     *   - 구글 서비스 의존성 추가 (bom:32.3.1)
     *      : implementation 'com.google.firebase:firebase-firestore:24.8.1'
     * // --------------------------------------------------------------------------------------
     * */





    /**
     * // --------------------------------------------------------------------------------------
     * TODO [빠른 로직 찾기 : 주석 로직 찾기]
     * // --------------------------------------------------------------------------------------
     * // [SEARCH FAST] : [Observable] : [Write] : [기본] 데이터베이스 SET 쓰기
     * // --------------------------------------------------------------------------------------
     * // [SEARCH FAST] : [Observable] : [Read] : [기본] 데이터베이스 SET 읽기
     * // --------------------------------------------------------------------------------------
     * // [SEARCH FAST] : [Observable] : [Delete] : [기본] 데이터베이스 SET 삭제
     * // --------------------------------------------------------------------------------------
     *
     * // --------------------------------------------------------------------------------------
     *
     * // --------------------------------------------------------------------------------------
     */





    // -----------------------------------------------------------------------------------------
    // TODO [전역 변수 선언]
    // -----------------------------------------------------------------------------------------
    private static final String ACTIVITY_NAME = "C_FirebaseRealDatabase";





    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [Observable] : [Write] : [기본] 데이터베이스 SET 쓰기
    // -----------------------------------------------------------------------------------------
    // TODO [호출 방법 소스 코드]
    // -----------------------------------------------------------------------------------------
    /*
    // [json 선언]
    JSONObject jsonObject = new JSONObject();
    jsonObject.put("name", "투케이");
    jsonObject.put("age", 30);

    C_FirebaseRealDatabase.observableSetWriteDatabase(A_Webview.this, "testJson", jsonObject.toString())
            .subscribeOn(AndroidSchedulers.mainThread()) // [Observable (생성자) 로직을 IO 스레드에서 실행 : 백그라운드]
            .observeOn(Schedulers.io()) // [Observer (관찰자) 로직을 메인 스레드에서 실행]
            .subscribe(new Observer<Boolean>() { // [Observable.create 타입 지정]
                @Override
                public void onSubscribe(@NonNull Disposable d) {
                }
                @Override
                public void onNext(@NonNull Boolean value) {
                }
                @Override
                public void onError(@NonNull Throwable e) {
                }
                @Override
                public void onComplete() {
                }
            });
    */
    // -----------------------------------------------------------------------------------------
    public static Observable<Boolean> observableSetWriteDatabase(Context mContext, String table, String json){

        // [로직 처리 실시]
        return Observable.create(subscriber -> {

            try {
                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] 데이터베이스 SET 쓰기 수행", new String[]{ "TABLE :: " + String.valueOf(table), "JSON : " + String.valueOf(json) });

                // TODO [방어 로직] : 널 체크
                if (C_Util.stringNotNull(table) == true && C_Util.stringNotNull(json) == true){

                    FirebaseDatabase database = FirebaseDatabase.getInstance(); // [인스턴스 생성]
                    DatabaseReference databaseReference = database.getReference();

                    // [테이블에 데이터 저장]
                    databaseReference.child(String.valueOf(table)).setValue(String.valueOf(json))
                            .addOnSuccessListener(new OnSuccessListener<Void>() {
                                @Override
                                public void onSuccess(Void aVoid) {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Write] [onSuccess] - RealDatabase Set Write", null);

                                    subscriber.onNext(true);
                                    subscriber.onComplete();
                                }
                            })
                            .addOnFailureListener(new OnFailureListener() {
                                @Override
                                public void onFailure(@NonNull Exception e) {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Write] [onFailure] - RealDatabase Set Write", new String[]{ "ERROR :: " + String.valueOf(e.getMessage()) });

                                    subscriber.onNext(false);
                                    subscriber.onComplete();
                                }
                            });

                }
                else {
                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Write] [Error] - RealDatabase Set Connection", new String[]{ "ERROR :: Input Data Is Null" });

                    subscriber.onNext(false);
                    subscriber.onComplete();

                }

            } catch (final Exception e){
                S_Log._printStackTrace_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase Set] [Write] [Exception]", null, e);

                // ------------------------------------------------------
                // TODO [리턴 데이터 반환]
                // ------------------------------------------------------
                try {
                    subscriber.onNext(false);
                    subscriber.onComplete();
                }
                catch (Exception ex){
                    ex.printStackTrace();
                }
            }

        });
    }





    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [Observable] : [Read] : [기본] 데이터베이스 SET 읽기
    // -----------------------------------------------------------------------------------------
    // TODO [호출 방법 소스 코드]
    // -----------------------------------------------------------------------------------------
    /*
    C_FirebaseRealDatabase.observableSetReadDatabase(A_Webview.this, "testUser")
            .subscribeOn(AndroidSchedulers.mainThread()) // [Observable (생성자) 로직을 IO 스레드에서 실행 : 백그라운드]
            .observeOn(Schedulers.io()) // [Observer (관찰자) 로직을 메인 스레드에서 실행]
            .subscribe(new Observer<String>() { // [Observable.create 타입 지정]
                @Override
                public void onSubscribe(@NonNull Disposable d) {
                }
                @Override
                public void onNext(@NonNull String value) {
                }
                @Override
                public void onError(@NonNull Throwable e) {
                }
                @Override
                public void onComplete() {
                }
            });
    */
    // -----------------------------------------------------------------------------------------
    public static Observable<String> observableSetReadDatabase(Context mContext, String table){

        // [로직 처리 실시]
        return Observable.create(subscriber -> {

            try {
                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] 데이터베이스 SET 읽기 수행", new String[]{ "TABLE :: " + String.valueOf(table) });

                // TODO [방어 로직] : 널 체크
                if (C_Util.stringNotNull(table) == true){

                    FirebaseDatabase database = FirebaseDatabase.getInstance(); // [인스턴스 생성]
                    DatabaseReference databaseReference = database.getReference();

                    // [테이블 데이터 읽기]
                    databaseReference.child(String.valueOf(table)).get().addOnCompleteListener(new OnCompleteListener<DataSnapshot>() {
                        @Override
                        public void onComplete(@NonNull Task<DataSnapshot> task) {
                            if (!task.isSuccessful()) {
                                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Read] [onFailure] - RealDatabase Set Read", new String[]{ "ERROR :: Input Data Is Null" });

                                subscriber.onNext("");
                                subscriber.onComplete();
                            }
                            else {
                                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Read] [onSuccess] - RealDatabase Set Read", new String[]{String.valueOf(task.getResult().getValue())});

                                subscriber.onNext(String.valueOf(task.getResult().getValue()));
                                subscriber.onComplete();
                            }
                        }
                    });

                }
                else {
                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Read] [Error] - RealDatabase Set Connection", new String[]{ "ERROR :: Input Data Is Null" });

                    subscriber.onNext("");
                    subscriber.onComplete();

                }

            } catch (final Exception e){
                S_Log._printStackTrace_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase Set] [Read] [Exception]", null, e);

                // ------------------------------------------------------
                // TODO [리턴 데이터 반환]
                // ------------------------------------------------------
                try {
                    subscriber.onNext("");
                    subscriber.onComplete();
                }
                catch (Exception ex){
                    ex.printStackTrace();
                }
            }

        });
    }





    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [Observable] : [Delete] : [기본] 데이터베이스 SET 삭제
    // -----------------------------------------------------------------------------------------
    // TODO [호출 방법 소스 코드]
    // -----------------------------------------------------------------------------------------
    /*
    C_FirebaseRealDatabase.observableSetDeleteDatabase(A_Webview.this, "testJson")
            .subscribeOn(AndroidSchedulers.mainThread()) // [Observable (생성자) 로직을 IO 스레드에서 실행 : 백그라운드]
            .observeOn(Schedulers.io()) // [Observer (관찰자) 로직을 메인 스레드에서 실행]
            .subscribe(new Observer<Boolean>() { // [Observable.create 타입 지정]
                @Override
                public void onSubscribe(@NonNull Disposable d) {
                }
                @Override
                public void onNext(@NonNull Boolean value) {
                }
                @Override
                public void onError(@NonNull Throwable e) {
                }
                @Override
                public void onComplete() {
                }
            });
    */
    // -----------------------------------------------------------------------------------------
    public static Observable<Boolean> observableSetDeleteDatabase(Context mContext, String table){

        // [로직 처리 실시]
        return Observable.create(subscriber -> {

            try {
                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] 데이터베이스 SET 삭제 수행", new String[]{ "TABLE :: " + String.valueOf(table) });

                // TODO [방어 로직] : 널 체크
                if (C_Util.stringNotNull(table) == true){

                    FirebaseDatabase database = FirebaseDatabase.getInstance(); // [인스턴스 생성]
                    DatabaseReference databaseReference = database.getReference();

                    // [테이블에 데이터 저장]
                    databaseReference.child(String.valueOf(table)).setValue(null)
                            .addOnSuccessListener(new OnSuccessListener<Void>() {
                                @Override
                                public void onSuccess(Void aVoid) {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Delete] [onSuccess] - RealDatabase Set Delete", null);

                                    subscriber.onNext(true);
                                    subscriber.onComplete();
                                }
                            })
                            .addOnFailureListener(new OnFailureListener() {
                                @Override
                                public void onFailure(@NonNull Exception e) {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Delete] [onFailure] - RealDatabase Set Delete", new String[]{ "ERROR :: " + String.valueOf(e.getMessage()) });

                                    subscriber.onNext(false);
                                    subscriber.onComplete();
                                }
                            });

                }
                else {
                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase] [Delete] [Error] - RealDatabase Set Connection", new String[]{ "ERROR :: Input Data Is Null" });

                    subscriber.onNext(false);
                    subscriber.onComplete();

                }

            } catch (final Exception e){
                S_Log._printStackTrace_(mContext, ACTIVITY_NAME + " : [Firebase] [RealDatabase Set] [Delete] [Exception]", null, e);

                // ------------------------------------------------------
                // TODO [리턴 데이터 반환]
                // ------------------------------------------------------
                try {
                    subscriber.onNext(false);
                    subscriber.onComplete();
                }
                catch (Exception ex){
                    ex.printStackTrace();
                }
            }

        });
    }


} // TODO [클래스 종료]

---