[PHP] PHP 외부 DB 연결

💡 PHP를 이용하여 외부 DB와 연결하여 사용하는 방법!

 

• 안드로이드 애플리케이션은 보안상의 이유로 ‘외부’ 데이터베이스에 바로 접근하지 못하기 때문에 (php+서버)를 중간에 두고 연결하여 사용해야 함

💡 코드 작성

 

• 먼저 build.gradle(App)파일에 서버 통신 관련 라이브러리인 implementation 'com.android.volley:volley:1.2.1' 을 추가해줘야 함

Activity에서 Response & Request 메서드 작성

1. Response Listener를 생성하고 onResponse()메서드 @Override한다.
2. JSONArray or JSONObject객체로 값을 반환 받아서 사용한다.
3. 마지막에는 RequestActivity객체에 전달할 값을 담아 생성하고 RequestQueue객체에 담는다.

private void donation(String category) {
        Response.Listener<String> responseListener = new Response.Listener<String>() {
            @Override
            public void onResponse(String response) {
                // 불러오기 전에 데이터(아이템) 초기화 해줘야 중첩 안됨.
                adapter.notifyDataSetChanged();
 
                try {
                    JSONArray jsonArray = new JSONArray(response);
                    JSONObject jsonObject;
 
                    for (int i = 0; i < jsonArray.length(); i++) {
 
                        jsonObject = (JSONObject) jsonArray.getJSONObject(i);
                        String titleName = jsonObject.getString("titleName");
                        String name = jsonObject.getString("name");
                        String nowStep = jsonObject.getString("nowStep");
                        String content = jsonObject.getString("content");
                        String date = jsonObject.getString("date");
                        String startDate = jsonObject.getString("startDate");
                        String maxStep = jsonObject.getString("maxStep");
                        String dNum = jsonObject.getString("dNum");
                        String contentImage = jsonObject.getString("contentImage");
 
                        DonationData mainData = new DonationData(dNum, titleName, name, nowStep, contentImage, content, date, startDate, maxStep);
                        arrayList.add(mainData);
                    }
 
                } catch (JSONException e) {
                    e.printStackTrace();
                }
            }
        };
        DonationRequest donationRequest = new DonationRequest(category, responseListener);
        RequestQueue queue = Volley.newRequestQueue(getActivity());
        queue.add(donationRequest);
    }

서버로 요청할 Request 파일 작성

1. 서버 URL설정 (php파일 연동)
2. Request클래스의 생성자 생성
   • 호출할 때 받아올 매개변수 지정
   • super()에 전송방식(POST), listener, errorListener지정
   • Map타입 객체에 서버로 전송할 값 담기

import android.util.Log;
 
import com.android.volley.AuthFailureError;
import com.android.volley.Request;
import com.android.volley.Response;
import com.android.volley.toolbox.StringRequest;
 
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
 
// Donation값 서버로 전송 (2023-03-18 우진 수정)
public class DonationInsertRequest extends StringRequest {
 
    final static private String URL = "<http://miraclestep01.dothome.co.kr/InsertDonation.php>"; // 서버 URL 설정 (PHP 파일 연동.)
    private Map<string, string=""> map;
 
    public DonationInsertRequest(int dNum, String userId, String userStep, Response.Listener listener) {
 
        // post방식으로 listener를 서버에 전송.
        super(Request.Method.POST, URL, listener, null);
 
        // 현재 날짜 구하기
        LocalDate now = LocalDate.now();
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
        String formatedNow = now.format(formatter);
 
        map = new HashMap<>();
        map.put("dNum", String.valueOf(dNum));
        map.put("userID", userId);
        map.put("userStep", userStep);
        map.put("ddate", String.valueOf(formatedNow));
 
        Log.d("어디", "인서트");
        Log.d("글번호", String.valueOf(dNum));
        Log.d("아이디", userId);
        Log.d("기부날짜", formatedNow);
    }
 
    @Override
    protected Map<string, string=""> getParams() throws AuthFailureError {
        return map;
    }
}
</string,></string,>

서버에 등록할 php 파일 작성

1. 서버 DB에 연결 - mysqli_connect()
   • ip주소, id, pw, database, 인코딩 설정
2. Request파일에서 Map객체에 담아 보낸 값 세팅
3. Sql문 작성 및 실행
   • mysqli_prepare(), mysqli_stmt_execute()
4. 결과 값 받아오기 및 결과 전송

select

<?php
  /*
      SelectUserDonation.php : 기부내역을 불러오는 php (POST 형식으로 MySQL로부터 데이터를 받아옴.)
      con : mysql 연결을 시도하는 변수.
      "$변수" 로 변수 선언
    */
 
/* (1) 서버 DB에 연결.*/
        $con = mysqli_connect("localhost", "miraclestep01", "비밀번호", "miraclestep01");  // mysql 연결, IP, 사용자명, 비밀번호, 데이터베이스
    mysqli_query($con, 'SET NAMES utf8'); // 인코딩을 utf-8로 세팅. (한글 전송이 가능해짐.)
 
    $userID = isset($_POST["userID"]) ? $_POST["userID"] : "test1234@naver.com";
 
    $statement = mysqli_prepare($con, "SELECT CampaignList.hostingGroup, CampaignList.title , DonationHistory.donationDate, DonationHistory.donationStep FROM CampaignList LEFT JOIN DonationHistory ON CampaignList.campaignIndex = DonationHistory.donationIndex WHERE DonationHistory.userId = ? ORDER BY DonationHistory.donationDate DESC");
    mysqli_stmt_bind_param($statement, "s", $userID);
    mysqli_stmt_execute($statement);
 
    //mysqli_stmt_store_result($statement);
    mysqli_stmt_bind_result($statement, $DonationGroup, $DonationName, $UserDonationDate, $UserDonationStep);
 
    /*$statement2 = mysqli_prepare($con, "SELECT DGroup, DName FROM Donation WHERE DNum = ".$DonationNumber);
    //mysqli_stmt_bind_param($statement2, "i", $DonationNumber);
    mysqli_stmt_execute($statement2);
 
    mysqli_stmt_store_result($statement2);
    mysqli_stmt_bind_result($statement2, $DonationGroup, $DonationName);*/
 
    $response = array();
    $allResponse = array();
    $response["success"] = false;
 
     while(mysqli_stmt_fetch($statement)){
 
        $response["success"] = true;
        $response["donationDate"] = $UserDonationDate;
        $response["donationStep"] = $UserDonationStep;
        $response["titleName"] = $DonationName;
        $response["groupName"] = $DonationGroup;
 
        $allResponse[] = $response;
    }
    echo json_encode($allResponse);
?>

insert

<?php
 /*
      InsertDonation.php : 걸음 수를 기부하는 사용자 php (POST 형식으로 MySQL로부터 데이터를 받아옴.)
      con : mysql 연결을 시도하는 변수.
      "$변수" 로 변수 선언
    */
 
/* (1) 서버 DB에 연결.*/
    $con = mysqli_connect("localhost", "miraclestep01", "비밀번호", "miraclestep01");
    mysqli_query($con, 'SET NAMES utf8');   /* 인코딩을 utf-8로 세팅. (한글 전송이 가능해짐.) */
 
/* (2) DB에 저장할 객체 선언. */
    $userID = isset($_POST["userID"]) ? $_POST["userID"] : "";
 
    // date타입을 php는 String으로 받아들이기 때문에 형변환
    $ddate = isset($_POST["ddate"]) ? $_POST["ddate"] : "";
    $ddate=str_replace(".","-",$ddate);
    $ddate=str_replace("/","-",$ddate);
    $ddate = date('Ymd', strtotime($ddate));
 
    $dNum = isset($_POST["dNum"]) ? $_POST["dNum"] : "";
    $userStep = isset($_POST["userStep"]) ? $_POST["userStep"] : "";
 
/* (3) DB안에 insert하는 문장. (UserDonation) */
    $statement = mysqli_prepare($con, "INSERT INTO DonationHistory (donationIndex, userId, donationDate, donationStep) VALUES (?,?,?,?)");
    mysqli_stmt_bind_param($statement, "issi", $dNum, $userID, $ddate, $userStep);
    mysqli_stmt_execute($statement);
 
/* (4) 성공 여부 전송. */
    $response = array();
    $response["success"] = true;
 
/* (5) 실행 결과 전송. */
    echo json_encode($response);
?>

update

<?php
 /*
      UpdateDonation.php : 해당 캠페인의 현재 기부된 걸음 수를 처리하는 php (POST 형식으로 MySQL로부터 데이터를 받아옴.)
      con : mysql 연결을 시도하는 변수.
      "$변수" 로 변수 선언
    */
 
/* (1) 서버 DB에 연결.*/
    $con = mysqli_connect("localhost", "miraclestep01", "비밀번호", "miraclestep01");
    mysqli_query($con, 'SET NAMES utf8');   /* 인코딩을 utf-8로 세팅. (한글 전송이 가능해짐.) */
 
/* (2) DB에 저장할 객체 선언. */
    $dNum = isset($_POST["dNum"]) ? $_POST["dNum"] : "0";
 
    $updateStep = isset($_POST["updateStep"]) ? $_POST["updateStep"] : "";
 
/* (3) DB안에 insert하는 문장. (Donation) */
    $statement = mysqli_prepare($con, "UPDATE CampaignList SET nowDonation = ? Where campaignIndex = ?");
    mysqli_stmt_bind_param($statement, "ii", $updateStep, $dNum);
    mysqli_stmt_execute($statement);
 
/* (4) 성공 여부 전송. */
    $response = array();
    $response["success"] = true;
 
    echo json_encode($response);
?>