<?php
class PatreonDatabaseHandler extends DatabaseHandler {
function init(){
$this->database = CONFIG_DB_NAME_GERMAN;
$this->username = CONFIG_DB_USER_GERMAN;
$this->password = CONFIG_DB_PWD_GERMAN;
}
function getPatreonData($userId){
$sql = "SELECT * FROM `" . $this->database . "`.`patreon` WHERE `user_id` = '".$userId."'";
$result = $this->connection->query($sql) or die($this->connection->error);
// $result = mysqli_fetch_row($result);
$result = mysqli_fetch_assoc($result);
return $result;
}
function updateOrInsert($userId, $patreonUserId, $accessToken, $refreshToken, $patreon_plan_id){
if($this->isPatreonUser($userId)){
$this->updatePatreonUser($userId, $patreonUserId, $accessToken, $refreshToken, $patreon_plan_id);
}
else {
$this->insertPatreonUser($userId, $patreonUserId, $accessToken, $refreshToken, $patreon_plan_id);
}
}
function isPatreonUser($userId){
$sql = "SELECT * FROM `" . $this->database . "`.`patreon` WHERE user_id='" . $userId . "'";
$result = $this->connection->query($sql) or die($this->connection->error);
$user = mysqli_fetch_assoc($result);
if (isset($user) && count($user) > 0)
return true;
else
return false;
}
function updatePatreonUser($userId, $patreonUserId, $accessToken, $refreshToken, $patreon_plan_id){
$sql = "UPDATE `" . $this->database
. "`.`patreon` set patreon_user_id='$patreonUserId'
,user_access_token='$accessToken'
,user_refresh_token='$refreshToken'
,time_stamp=NOW()
,patreon_plan_id='$patreon_plan_id' where
user_id like '$userId'";
$result = $this->connection->query($sql) or die($this->connection->error);
}
function insertPatreonUser($userId, $patreonUserId, $accessToken, $refreshToken, $patreon_plan_id){
$sql = "INSERT INTO `" . $this->database . "`.`patreon` (
`user_id`,`patreon_user_id`,`patreon_plan_id`,`user_access_token`,`user_refresh_token`)
VALUES ('"
. $userId . "' ,'"
. $patreonUserId . "' ,'"
. $patreon_plan_id . "' ,'"
. $accessToken . "' ,'"
. $refreshToken . "'"
. ");";
$result = $this->connection->query($sql) or die($this->connection->error);
}
}