04. Firebase Realtime Database - Select

🔷 Select Data

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.UI;
using TMPro;

// Firebase 네임스페이스 선언
using Firebase;
using Firebase.Database;

// Firebase에 저장할 데이터 구조
public class User
{
    public string userName;
    public int gold;

    // 생성자
    public User(string _userName, int _gold)
    {
        this.userName = _userName;
        this.gold = _gold;
    }

}

public class FirebaseManager : MonoBehaviour
{
    // 저장할 데이터 UI
    public InputField userName;
    public InputField gold;

    // 로드한 모든 데이터를 출력할 UI
    public TMP_Text allDataField;
    private bool isLoad = false;
    private string allDataStr = "";

    // 선택한 데이터를 출력할 UI
    public TMP_Text selectDataField;
    private Query userNameQuery;

    // 파이어베이스 레퍼런스를 전역 선언
    private DatabaseReference reference;
    // 파이어베이스 데이터베이스의 고유주소(URI)
    private readonly string uri = "https://fir-demo-3c2bb-default-rtdb.firebaseio.com/";

    void Awake()
    {
        // 앱 속성 생성
        AppOptions options = new AppOptions();
        options.DatabaseUrl = new System.Uri(uri);
        // 앱을 생성
        FirebaseApp app = FirebaseApp.Create(options);
    }

    void Start()
    {
        reference = FirebaseDatabase.DefaultInstance.RootReference; // 데이터베이스의 루트를 참조

        allDataField.text = "Start";
    }

    // 데이터 등록
    public void InsertData()
    {
        // UI 입력값
        string _userName = userName.text;
        int _gold = int.Parse(gold.text);

        // 데이터 저장을 위한 클래스 생성
        User user = new User(_userName, _gold);

        // Json 포맷으로 포맷팅
        string json = JsonUtility.ToJson(user);
        // UserData 노드를 생성하고, 하위에 데이터를 추가
        reference.Child("UserData").Child(_userName).SetRawJsonValueAsync(json);
    }

    /*
        데이터 조회
        - GetValueAsync 사용
        - 비동기 방식, 호출완료된 후 데이터 가공
    */
    public void LoadAllData()
    {
        // 지역 레퍼런스 선언
        DatabaseReference reference = FirebaseDatabase.DefaultInstance.GetReference("UserData");
        // 데이터 조회
        reference.GetValueAsync().ContinueWith(task =>
        {
            if (task.IsFaulted)  // 데이터 로딩 실패
            {
                Debug.LogError("Failed load data!!!");
            }
            else if (task.IsCompleted)  // 데이터 로딩 성공
            {
                // 스냅샷 생성 : 조회한 데이터(레코드)를 저장하는 단위
                DataSnapshot snapshot = task.Result;

                // 데이터 건수 출력
                Debug.Log($"데이터 레코드 갯수 : {snapshot.ChildrenCount}");
                // 데이터 출력
                allDataStr = "";
                foreach (DataSnapshot data in snapshot.Children)
                {
                    // DataSnapshot.Value 데이터를 접근
                    // {키}:{값} IDictionary 자료형 사용 (Key:Value)
                    IDictionary _data = (IDictionary)data.Value;
                    allDataStr = allDataStr + $"Name : {_data["userName"]} , Gold : {_data["gold"]}\n";
                }
                isLoad = true;
            }
        });
        StartCoroutine(UpdateAllData());
    }

    IEnumerator UpdateAllData()
    {
        yield return new WaitUntil(() => isLoad);
        isLoad = false;
        allDataField.text = allDataStr;
    }


    // 키 값으로 검색
    public void SelectData()
    {
        // 검색할 UI 입력항목
        string _userName = userName.text;
        // 지역 레퍼런스 선언
        DatabaseReference reference = FirebaseDatabase.DefaultInstance.GetReference("UserData");
        // 정렬, 추출 Query
        // Query userNameQuery = reference.OrderByChild("userName").EqualTo(_userName);
        userNameQuery = reference.OrderByChild("userName").EqualTo(_userName);



        // 검색
        // 검색이 완료되면 or 값이 변경되면
        // ValueChanged : 이벤트 함수
        userNameQuery.ValueChanged += OnDataLoaded;
    }

    // Query 결과값을 출력하는 함수
    void OnDataLoaded(object sender, ValueChangedEventArgs args)
    {
        // 데이터 조회 스냅샷 정의
        DataSnapshot snapshot = args.Snapshot;

        foreach (var data in snapshot.Children)
        {
            IDictionary _data = (IDictionary)data.Value;
            selectDataField.text = $"Name : {_data["userName"]}, Gold : {_data["gold"]}";
        }
    }

}

- userNameQuery.ValueChanged += OnDataLoaded;

    - 함수 연결. 연결하면서 OnDataLoaded 함수가 무조건 한번 실행됨.

    - userNameQuery 값이 변하면 OnDataLoaded() 함수를 실행

 

 

 

- TMP_text 생성 : Text (TMP) - Select Data

 

 

 

- 연결

 

 

 

- 버튼 생성 : Button - Select

 

 

 

- 이벤트 연결 : SelectData()

 

 

 

- play

- Ojui_1 입력 > Select 버튼 클릭

- 해당 값이 나오는 것을 확인

 

 

 

- Ojui_1, 900 입력 > Insert 버튼 클릭

- Insert를 하여 Ojui_1의 값을 변경하니, Select한 데이터의 값이 저절로 업데이트된 것을 확인

 

 

 

🔶 값 변경할 때마다 저절로 업데이트되지 않도록 처리

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.UI;
using TMPro;

// Firebase 네임스페이스 선언
using Firebase;
using Firebase.Database;

// Firebase에 저장할 데이터 구조
public class User
{
    public string userName;
    public int gold;

    // 생성자
    public User(string _userName, int _gold)
    {
        this.userName = _userName;
        this.gold = _gold;
    }

}

public class FirebaseManager : MonoBehaviour
{
    // 저장할 데이터 UI
    public InputField userName;
    public InputField gold;

    // 로드한 모든 데이터를 출력할 UI
    public TMP_Text allDataField;
    private bool isLoad = false;
    private string allDataStr = "";

    // 선택한 데이터를 출력할 UI
    public TMP_Text selectDataField;
    private Query userNameQuery;

    // 파이어베이스 레퍼런스를 전역 선언
    private DatabaseReference reference;
    // 파이어베이스 데이터베이스의 고유주소(URI)
    private readonly string uri = "https://fir-demo-3c2bb-default-rtdb.firebaseio.com/";

    void Awake()
    {
        // 앱 속성 생성
        AppOptions options = new AppOptions();
        options.DatabaseUrl = new System.Uri(uri);
        // 앱을 생성
        FirebaseApp app = FirebaseApp.Create(options);
    }

    void Start()
    {
        reference = FirebaseDatabase.DefaultInstance.RootReference; // 데이터베이스의 루트를 참조

        allDataField.text = "Start";
    }

    // 데이터 등록
    public void InsertData()
    {
        // UI 입력값
        string _userName = userName.text;
        int _gold = int.Parse(gold.text);

        // 데이터 저장을 위한 클래스 생성
        User user = new User(_userName, _gold);

        // Json 포맷으로 포맷팅
        string json = JsonUtility.ToJson(user);
        // UserData 노드를 생성하고, 하위에 데이터를 추가
        reference.Child("UserData").Child(_userName).SetRawJsonValueAsync(json);
    }

    /*
        데이터 조회
        - GetValueAsync 사용
        - 비동기 방식, 호출완료된 후 데이터 가공
    */
    public void LoadAllData()
    {
        // 지역 레퍼런스 선언
        DatabaseReference reference = FirebaseDatabase.DefaultInstance.GetReference("UserData");
        // 데이터 조회
        reference.GetValueAsync().ContinueWith(task =>
        {
            if (task.IsFaulted)  // 데이터 로딩 실패
            {
                Debug.LogError("Failed load data!!!");
            }
            else if (task.IsCompleted)  // 데이터 로딩 성공
            {
                // 스냅샷 생성 : 조회한 데이터(레코드)를 저장하는 단위
                DataSnapshot snapshot = task.Result;

                // 데이터 건수 출력
                Debug.Log($"데이터 레코드 갯수 : {snapshot.ChildrenCount}");
                // 데이터 출력
                allDataStr = "";
                foreach (DataSnapshot data in snapshot.Children)
                {
                    // DataSnapshot.Value 데이터를 접근
                    // {키}:{값} IDictionary 자료형 사용 (Key:Value)
                    IDictionary _data = (IDictionary)data.Value;
                    allDataStr = allDataStr + $"Name : {_data["userName"]} , Gold : {_data["gold"]}\n";
                }
                isLoad = true;
            }
        });
        StartCoroutine(UpdateAllData());
    }

    IEnumerator UpdateAllData()
    {
        yield return new WaitUntil(() => isLoad);
        isLoad = false;
        allDataField.text = allDataStr;
    }


    // 키 값으로 검색
    public void SelectData()
    {
        // 검색할 UI 입력항목
        string _userName = userName.text;
        // 지역 레퍼런스 선언
        DatabaseReference reference = FirebaseDatabase.DefaultInstance.GetReference("UserData");
        // 정렬, 추출 Query
        // Query userNameQuery = reference.OrderByChild("userName").EqualTo(_userName);
        userNameQuery = reference.OrderByChild("userName").EqualTo(_userName);



        // 검색
        // 검색이 완료되면 or 값이 변경되면
        // ValueChanged : 이벤트 함수
        userNameQuery.ValueChanged += OnDataLoaded;
    }

    // Query 결과값을 출력하는 함수
    void OnDataLoaded(object sender, ValueChangedEventArgs args)
    {
        // 데이터 조회 스냅샷 정의
        DataSnapshot snapshot = args.Snapshot;

        foreach (var data in snapshot.Children)
        {
            IDictionary _data = (IDictionary)data.Value;
            selectDataField.text = $"Name : {_data["userName"]}, Gold : {_data["gold"]}";
        }
        userNameQuery.ValueChanged -= OnDataLoaded;
    }

}

- userNameQuery.ValueChanged -= OnDataLoaded; : 추가

 

 

 

- Ojui_1을 Select >  Ojui_1, 100 Insert > Load

- 값이 바뀌어도 저절로 업데이트되지 않는 것을 확인