node.js + mysql + Unity 연동

var express = require('express');
var app = express();
var mysql_dbc = require('./db_con')();
var body_parser = require('body-parser');
 
//app.use(body_parser());
app.use(express.json());
 
app.get('/', (req, res)=>{
    res.send("connected.");
});
 
app.get('/personList', (req, res)=>{
    var connection = mysql_dbc.init();
    mysql_dbc.test_poen(connection);
    var query = "select * from persons";
    connection.query(query, (err, result, fields)=>{
        if(err) throw err;
        console.log(result);
        connection.end();
        res.send(result); 
    });
});
 
app.post('/addPerson', (req, res)=>{
 
    console.log(req.body);
 
    var firstName = req.body.firstName;
    var lastName = req.body.lastName;
    var age = req.body.age;
 
    console.log(firstName, lastName, age);
 
    var connection = mysql_dbc.init();
    mysql_dbc.test_poen(connection);
    var query = 'insert into persons (firstname, lastname, age) values (?, ?, ?)';
    var params = [firstName, lastName, age];
    connection.query(query, params, (err, result, fields)=>{
        if(err) throw err;
        console.log(result);
    });
 
});
 
app.post('/updateAge', (req, res)=>{
    console.log(req.body);
    var id = req.body.id;
    var age = req.body.age;
 
    var connection = mysql_dbc.init();
    mysql_dbc.test_poen(connection);
    var query = 'update persons set age = ? where id = ?';
    var params = [age, id];
    connection.query(query, params, (err, result, fields)=>{
        if(err) throw err;
        console.log(result);
    });
});
 
app.post 
app.listen(3000, ()=>{
    console.log("server started!");
});

var mysql = require('mysql');
var conf = require('./db_info').local;
 
module.exports = function(){
    return {
        init : function (){
            return mysql.createConnection({
                host: conf.host,
                port: conf.port,
                user: conf.user,
                password: conf.password,
                database: conf.database
            });
        },
 
        test_poen : function(con){
            
            con.connect(function(err){
                if(err){
                    console.error('mysql connection failed' + err);
                }else{
                    console.info('mysql is connected');
 
                    
                }
            })
        }
    }
};

module.exports =(
    function(){
        return {
            local: {
                host : 'localhost',
                port : '3306',
                user : 'root',
                password : '000000',
                database : 'testdb'
            }
        }
    }
)();

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.Networking;
using Newtonsoft.Json;
 
//[System.Serializable]
public class add_person
{
    public string firstName;
    public string lastName;
    public int age;
 
    public add_person(string firstName, string lastName, int age)
    {
        this.firstName = firstName;
        this.lastName = lastName;
        this.age = age;
    }
}
 
public struct update_age
{
    public int id;
    public int age;
}
 
public class Test : MonoBehaviour {
    
    public object[] Encording { get; private set; }
    private List<PersonData> personDataList;
 
    // Use this for initialization
    void Start () {
        
    }
 
    IEnumerator AddPerson(PersonData personData)
    {
        var add_person = new add_person(personData.firstName, personData.lastName, personData.age);
 
        var json = JsonConvert.SerializeObject(add_person);
 
        Debug.LogFormat("{0}", json);
 
        List<IMultipartFormSection> formData = new List<IMultipartFormSection>();
        formData.Add(new MultipartFormDataSection("data", json));
 
        UnityWebRequest www = UnityWebRequest.Post("localhost:3000/addPerson", formData);
        yield return www.SendWebRequest();
 
        if (www.isNetworkError || www.isHttpError)
        {
            Debug.LogFormat("{0}", www.error);
        }
        else {
            Debug.LogFormat("{0}", www.downloadHandler.text);
        }
 
        
    }
 
    IEnumerator GetPersons()
    {
        using (UnityWebRequest www = UnityWebRequest.Get("localhost:3000/personList"))
        {
            yield return www.SendWebRequest();
 
            if (www.isNetworkError || www.isHttpError)
            {
                Debug.Log(www.error);
            }
            else {
                Debug.Log(www.downloadHandler.text);
 
                byte[] results = www.downloadHandler.data;
 
                var json = System.Text.Encoding.Default.GetString(results);
 
                Debug.LogFormat("{0} {1}", results.Length, json);
 
                this.personDataList = JsonConvert.DeserializeObject<List<PersonData>>(json);
 
                foreach (var data in this.personDataList)
                {
                    Debug.LogFormat("{0}, {1}, {2}, {3}", data.id, data.firstName, data.lastName, data.age);
                }
            }
        }
    }
 
    // server side post data is null ?
    //https://stackoverflow.com/questions/43292700/unitywebrequest-downloadhandler-returning-null-while-getting-response-from-node?rq=1
    IEnumerator Post(string uri , string b)
    {
 
        byte[] bytes = System.Text.Encoding.ASCII.GetBytes(b);
 
        using (UnityWebRequest www = new UnityWebRequest(uri, UnityWebRequest.kHttpVerbPOST))
        {
            UploadHandlerRaw uH = new UploadHandlerRaw(bytes);
            DownloadHandlerBuffer dH = new DownloadHandlerBuffer();
 
            www.uploadHandler = uH;
            www.downloadHandler = dH;
            www.SetRequestHeader("Content-Type", "application/json");
            yield return www.SendWebRequest();
 
            if (www.isHttpError || www.isNetworkError)
            {
                Debug.Log(www.error);
            }
            else
            {
                Debug.Log(www.ToString());
                Debug.Log(www.downloadHandler.text);
            }
        }
    }
 
    IEnumerator UpdateAge(string uri, string data)
    {
        var bytes = System.Text.Encoding.UTF8.GetBytes(data);
        using (UnityWebRequest www = new UnityWebRequest(uri, UnityWebRequest.kHttpVerbPOST))
        {
            UploadHandlerRaw uh = new UploadHandlerRaw(bytes);
            DownloadHandlerBuffer dh = new DownloadHandlerBuffer();
            www.uploadHandler = uh;
            www.downloadHandler = dh;
            www.SetRequestHeader("Content-Type", "application/json");
            yield return www.SendWebRequest();
 
            if (www.isNetworkError || www.isHttpError)
            {
                Debug.LogFormat("{0}", www.isHttpError);
            }
            else {
                Debug.LogFormat("{0}", www.downloadHandler.text);
            }
        }
 
        
    }
 
 
    private void OnGUI()
    {
        if (GUILayout.Button("GET", GUILayout.Width(100), GUILayout.Height(60)))
        {
            StartCoroutine(GetPersons());
        }
 
        if (GUILayout.Button("POST", GUILayout.Width(100), GUILayout.Height(60)))
        {
            var personData = new PersonData("aaaaaaa", "bbbbbb", 1234);
            //StartCoroutine(AddPerson(personData));
            var json = JsonConvert.SerializeObject(personData);
            StartCoroutine(this.Post("localhost:3000/addPerson", json));
        }
 
        if (GUILayout.Button("UPDATE", GUILayout.Width(100), GUILayout.Height(60)))
        {
            var update_age = new update_age();
            update_age.id = 7;
            update_age.age = 11;
            var json = JsonConvert.SerializeObject(update_age);
            StartCoroutine(this.UpdateAge("localhost:3000/updateAge", json));
        }
 
        if (GUILayout.Button("DELETE", GUILayout.Width(100), GUILayout.Height(60)))
        {
 
        }
    }
}
 

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
 
public class PersonData  {
    public int id;
    public string firstName;
    public string lastName;
    public int age;
 
    public PersonData(string firstName, string lastName, int age)
    {
        this.firstName = firstName;
        this.lastName = lastName;
        this.age = age;
    }
}