(유니티3D) php와 mysql로 서버 DB 이용하기 2 (코드)

글 작성에 앞서 DB에 송수신 하는 데이터 집합체는 JSON을 활용함을 알려드립니다.

JSON과 AES 암호화 

이 글에서 사용한 JsonHelper를 이용해서 JSON 배열을 수신 할 것이기에 한 번 보고 오시는 것을 추천드립니다.

많은 분들이 MIniJson이나 SimpleJson이라는 C# 스크립트를 사용하시던데 다소 복잡한거 같아 여기서는 간단한 JsonHelper를 그대로 사용합니다.

JsonHelper로 저장이 되면 {"items":[{"no":0,"name":"이름","score":6000}]} 이런 형식으로 저장됩니다.

대괄호 [ ] 안에 들어가는 것은  json 화 된 데이터 클래스의 형태이므로 그 외의 형태를 직접 php에서 붙여준 다음 출력하는 것으로 JsonHelper를 통해 배열 수신이 가능합니다.

JsonHelper를 통한 배열 송신은 시도해보지 않았습니다. 배열을 DB로 송신할 일은 없으리라 생각되기에..

php에서 print나 echo를 통해 출력되는 모든 문자열은 이어져서 유니티에서 www.text로 받을 수 있습니다.

여기서는 하나의 C# 스크립트와 php만으로 구현했기에 한 번에 모든 데이터를 포함하여 송수신 하고 있습니다.

아래의 코드에서 php의 주소와 DB의 사용자 정보 부분을 바꿔뒀기 때문에 아래 코드를 그대로 복붙 하시면 작동하지 않습니다. 참고로만 봐주세요.

저도 아직 SQL과 php를 잘 다루는 편이 아니고 유니티와 php 간의 데이터 주고받는 방식을 완전히 활용하지 못하고 있기에 아래 코드는 다소 비효율적일 수 있으니 감안해주시면 감사하겠습니다.

using System.Collections;
using System.Collections.Generic;
using System;
using System.IO;
using UnityEngine;
using UnityEngine.UI;
 
public class testServer : MonoBehaviour {
 
    public enum eSuccessed { FAIL, SUCCESS }    //DB와의 연결이 잘 되었는지
    public enum eDBQuery { INSERT_UPDATE, DELETE, SELECT }  //입력한 데이터를 어떤 용도로 DB에 전달할 것인지
 
    [System.Serializable]
    public class Ranking
    {
        public int no;      //고유번호
        public string name; //이름
        public int score;   //점수
    }
    
    public eDBQuery dbQuery;
    public Ranking rank;
    eSuccessed successed;
 
    string phpUrl = "http://--------------------.php";    //php 주소
 
    // Use this for initialization
    void Awake () {
        StartCoroutine(LoadFromPhp());  //바로 코루틴을 시작
    }
 
    IEnumerator LoadFromPhp()
    {
        string load;
        Ranking[] infos;
        WWWForm urlForm = new WWWForm();
        urlForm.AddField("db_host", "localhost");   //php로 전송할 데이터를 같이 포함시킨다. php에선 $_POST["db_host"]; 의 형태로 받는다. 
        urlForm.AddField("db_user", "아이디");
        urlForm.AddField("db_passwd", "비밀번호");
        urlForm.AddField("db_name", "데이터베이스 ");
        urlForm.AddField("DBQuery", (int)dbQuery);
 
        switch (dbQuery)   //입력한 데이터를 어떤 용도로 DB에 전달할 것인지에 따라 추가 데이터를 포함시킨다.
        {
            case eDBQuery.INSERT_UPDATE:
                urlForm.AddField("insertRank", JsonUtility.ToJson(rank));   //삽입, 갱신에는 데이터 전부가 필요하므로 데이터 클래스를 JSON 화 시켜서 포함시킨다.
                break;
            case eDBQuery.DELETE:
                urlForm.AddField("deleteNo", rank.no);  //삭제에는 고유번호만 있으면 된다.
                break;
            case eDBQuery.SELECT:   //DB 데이터 보기
                break;
            default:
                Debug.Log("DB접근오류1");
                break;
        }
        
        WWW www = new WWW(phpUrl, urlForm); //php를 호출한다.
    
        yield return www;   //응답이 돌아올때까지 대기한다. 이 대기시간 때문에 코루틴으로 진행한다.
 
        if (www.error != null)  //php 접근 자체에 문제가 있으면 www.error가 발생한다.
        {
            Debug.Log("www에러" + www.error);
        }
        else
        {
            //에러가 없다면 php로부터 출력된게 모두 www.text에 포함되어 돌아온다. php에서 이 구분을 ;으로 하였으므로
            string[] successSplit = www.text.Split(';');    //Split함수로 나눠준다.
            //이 코드에선 정상적으로 이루어졌을 때 successSplit 안에는 2개가 들어간다. 성공 여부와 DB로부터 받은 데이터
            foreach (string s in successSplit)
                Debug.Log(s);   //두 개가 들어있는지 확인해본다.
            successed = (eSuccessed)Enum.Parse(typeof(eSuccessed), successSplit[0]);
            //분리된 앞쪽엔 성공 여부가 담겨있다. 보기 편하도록 enum형으로 만들어준다.
            switch(successed)
            {
                case eSuccessed.FAIL:   //실패했다면 에러문구를 띄운다.
                    Debug.Log("데이터베이스 에러: " + successSplit[1]);
                    break;
                case eSuccessed.SUCCESS:    //성공했다면 애초에 여기서부터 작업 종류를 정했으므로 작업 종류까지 되돌려받을 필요는 없으므로 위에서 정해둔 값을 이용해 처리하면 된다.
                    switch (dbQuery)
                    {
                        //삽입 및 갱신, 삭제는 돌려받는것이 없지만 잘 들어갔는지 확인을 위해 삽입 후 모든 데이터를 되돌리도록 하였다.
                        //자세한 설명은 SELECT 문에서 작성
                        case eDBQuery.INSERT_UPDATE:
                            File.WriteAllText(Path.Combine(Application.streamingAssetsPath, "jsonServer.json"), successSplit[1]);
                            load = File.ReadAllText(Path.Combine(Application.streamingAssetsPath, "jsonServer.json"));
                            infos = JsonHelper.FromJson<Ranking>(load);
                            Debug.Log("랭킹 추가");
                            foreach (Ranking info in infos)
                            {
                                Debug.Log("no: " + info.no + "  name: " + info.name + "  score: " + info.score);
                            }
                            break;
                        case eDBQuery.DELETE:
                            File.WriteAllText(Path.Combine(Application.streamingAssetsPath, "jsonServer.json"), successSplit[1]);
                            load = File.ReadAllText(Path.Combine(Application.streamingAssetsPath, "jsonServer.json"));
                            infos = JsonHelper.FromJson<Ranking>(load);
                            Debug.Log("삭제");
                            foreach (Ranking info in infos)
                            {
                                Debug.Log("no: " + info.no + "  name: " + info.name + "  score: " + info.score);
                            }
                            break;
                        case eDBQuery.SELECT:
                            //JsonHelper를 활용하여 배열을 인식하는 방식은 successSplit[1] 상태로는 인식하지 못한다.
                            //그러므로 한 번 파일로 저장한 후에 다시 불러온다. 그러면 정상적으로 인식한다.
                            File.WriteAllText(Path.Combine(Application.streamingAssetsPath, "jsonServer.json"), successSplit[1]);
                            load = File.ReadAllText(Path.Combine(Application.streamingAssetsPath, "jsonServer.json"));
                            infos = JsonHelper.FromJson<Ranking>(load);
 
                            foreach (Ranking info in infos)
                            {
                                Debug.Log("no: " + info.no + "  name: " + info.name + "  score: " + info.score);
                            }
                            break;
                        default:
                            Debug.Log("DB접근오류2");
                            break;
                    }
                    break;
                default:
                    Debug.Log("성공여부 에러");
                    break;
            }
        }
    }
}

<?php    
    //php에는 Enum이 없다고 하여 define으로 비슷하게 만들어주었다.
    //유니티 C# 스크립트의 Enum과 동일하게 만들어준다.
    define('FAIL', "0;");
    define('SUCCESS', "1;");    //문자에 포함하여 다시 유니티로 반환해줄 것이므로 ;을 포함한 문자로 define
    $i = 0;
    define('INSERT_UPDATE', $i++);
    define('DELETE', $i++);
    define('SELECT', $i++);    
    
    $db_host = $_POST["db_host"];    //유니티로부터 DB 접속 정보를 받아서 대입한다.
    $db_user = $_POST["db_user"];
    $db_passwd = $_POST["db_passwd"];
    $db_name = $_POST["db_name"];
    
    $conn = mysqli_connect($db_host, $db_user, $db_passwd, $db_name)    //mysqli를 통해 접속한다. i가 붙은게 훨씬 빠르고 안정성이 높다고 한다.
        or die(FAIL."데이터베이스 연결 중에 문제가 발생하였습니다.");    //실패하면 php를 종료하고 실패 문구 출력
 
    $DBQuery = $_POST["DBQuery"];    //유니티로부터 Enum을 넘겨받는다.
    
    switch ($DBQuery) {
    case INSERT_UPDATE:
        $DBInsert = $_POST["insertRank"];    //삽입, 갱신 시엔 유니티로부터 데이터를 json으로 받는다.
        $DBInsert = json_decode($DBInsert, true);    //그러므로 다시 json을 풀어준다.
        $InsertNo = $DBInsert["no"];
        $InsertName = $DBInsert["name"];
        $InsertScore = $DBInsert["score"];    //각 데이터를 분리한다.
        $query = "INSERT INTO testTable VALUES ($InsertNo, '$InsertName', $InsertScore)
            ON DUPLICATE KEY UPDATE score = IF(score < $InsertScore , $InsertScore, score)";    //분리한 것을 각각 쿼리에 채워서 삽입 및 갱신한다.
            //ON DUPLICATE KEY UPDATE는 중복된 데이터가 있을 때 갱신시켜준다. 점수가 이전보다 낮아지면 안되므로 이전보다 높을 때만 갱신시킨다.
        $result = mysqli_query($conn, $query); //쿼리 전송
        if($result)
        {
            SelectAll($conn);    //필요없지만 확인을 위해 DB 내의 모든 데이터를 출력한다.
        }
        else
        {
            echo FAIL.mysqli_error($conn);    //실패 이유를 보낸다.
            mysqli_close($conn);    //연결 된 DB를 해제한다.
            exit;
        }
        break;
    case DELETE:
        $deleteNo = $_POST["deleteNo"];    //삭제는 고유번호만 있어도 가능하다.
        $query = "DELETE FROM testTable WHERE no = $deleteNo";
        $result = mysqli_query($conn, $query);
        if($result)
        {
            SelectAll($conn);
        }
        else
        {
            echo FAIL.mysqli_error($conn);
            mysqli_close($conn);
            exit;
        }
        break;
    case SELECT:
        $query= "SELECT * FROM testTable order by score DESC LIMIT 0, 20";    //위와 동일하게 전부 출력하나 점수 내림차순으로 최대 20개만 출력한다.
        $result = mysqli_query($conn, $query);
    
        if($result)
        {
            $jsonText = "";    //문자열 초기화
            echo SUCCESS."{\"items\":[";    //성공Enum을 포함하고 JsonHelper의 양식과 동일하게 만들어주기 위한 모양새를 만들어준다.
            while($r = mysqli_fetch_assoc($result))    //DB로부터 받은 데이터의 마지막까지 반복
            {
                $jsonText = $jsonText.json_encode($r, JSON_UNESCAPED_UNICODE | JSON_NUMERIC_CHECK).",";    //받은 데이터를 json화 시켜서 $jsonText뒤에 계속 붙인다.
                                                    //JSON_UNESCAPED_UNICODE 이것을 붙여야 한글이 정상적으로 출력된다.
            }
            $jsonText = substr($jsonText, 0, -1);    //마지막 ','은 삭제시킨다.
            echo $jsonText;
            echo "]}";    //JsonHelper의 양식과 동일하게 만들어주기 위한 모양새를 붙여준다.
        }
        else
        {
            echo FAIL.mysqli_error($conn);
            mysqli_close($conn);
            exit;
        }
        break;
    default:
        echo FAIL."쿼리문 종류 전달 중 오류 발생";
        break;
}
    
    mysqli_close($conn); // close
 
    function SelectAll($_conn)
    {
        $query= "SELECT * FROM testTable";
        $result = mysqli_query($_conn, $query);
    
        if($result)
        {
            $jsonText = "";
            echo SUCCESS."{\"items\":[";
            while($r = mysqli_fetch_assoc($result))
            {
                $jsonText = $jsonText.json_encode($r, JSON_UNESCAPED_UNICODE | JSON_NUMERIC_CHECK).",";
            }
            $jsonText = substr($jsonText, 0, -1);
            echo $jsonText;
            echo "]}";
        }
    }
?>

이 코드를 유니티에서 보면

인스펙터 창에선 이렇게 보입니다.

게임에 적용한다면 게임 내 데이터를 알아서 적용해야겠지만 여기선 테스트이므로 직접 입력토록 했습니다.

현재 DB 테이블은 세팅되어있으며 비어있습니다. 이 조건을 작동시키면 삽입이 되겠지요.

실행시키면 이와 같이 4개의 로그가 뜹니다.

1은 SUCCESS를 뜻합니다.

{"items":[{~~  이건 JsonHelper에서 읽어들이기 위한 형태의 DB 출력값입니다.

이 둘이 각각 successSplit[0]과 successSplit[1]에 들어있습니다.

no: 0 name: 테스트1 score: 6000 는 받은 DB 출력값을 분리 작업을 거쳐 하나하나 출력한 것입니다.

매우 정상적으로 잘 작동합니다.