<?php
+/* Copyright 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013 Arun Persaud <arun@nubati.net>
+ *
+ * This file is part of e-DoKo.
+ *
+ * e-DoKo is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * e-DoKo is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with e-DoKo. If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
/* make sure that we are not called from outside the scripts,
* use a variable defined in config.php to check this
*/
function DB_open()
{
+ $version_needed = 5;
+
global $DB,$DB_user,$DB_host,$DB_database,$DB_password;
- $DB = @mysql_connect($DB_host,$DB_user, $DB_password);
- if ( $DB )
+ $DB = new mysqli($DB_host,$DB_user, $DB_password, $DB_database);
+ if ( $DB->connect_errno )
{
- mysql_select_db($DB_database) or die('Could not select database');
- }
- else
- {
- echo mysql_errno() . ": " . mysql_error(). "\n";
+ echo "Failed to connect to Mysql ".$DB->connect_error." (".$DB->connect_errno.")\n";
return -1;
- }
+ };
+
+ $version = DB_get_version();
+ if ($version != $version_needed)
+ return -2;
+
return 0;
}
function DB_close()
{
global $DB;
- mysql_close($DB);
+ $DB->close();
return;
}
function DB_quote_smart($value)
{
+ global $DB;
/* Stripslashes */
if (get_magic_quotes_gpc()) {
$value = stripslashes($value);
}
/* Quote if not a number or a numeric string */
if (!is_numeric($value)) {
- $value = "'" . mysql_real_escape_string($value) . "'";
+ $value = "'" . $DB->real_escape_string($value) . "'";
+ $value = addcslashes($value, '%_');
}
return $value;
}
/* use Mysql in the background */
function DB_query($query)
{
+ global $DB;
/* debug/optimize the database
$time = microtime();
- $return = mysql_query($query);
- $time = $time - microtime();
+ $return = $DB->query($query);
+ $time = microtime() - $time;
- if($time > 0.05) // this way we can find only the long ones
+ if($time > 0.15) // this way we can find only the long ones
{
- $logfile=fopen('/tmp/DBlog.log','a+');
- fwrite($logfile,"EXPLAIN $query ;\n");
- fwrite($logfile,"time of above query: $time\n");
+ $logfile=fopen('DBlog.log','a+');
+ fwrite($logfile,"time of query: $time\n");
+ fwrite($logfile,wordwrap(" EXPLAIN $query ;\n", 60, "\n "));
+
+ $result = "";
+ $queryresult = mysql_query("EXPLAIN $query ;");
+ if( $queryresult )
+ while($row = DB_fetch_array($queryresult))
+ $result .= " |".implode("|",$row)."|\n";
+
+ fwrite($logfile,"$result \n\n");
fclose($logfile);
};
return $return;
*/
- return mysql_query($query);
+ return $DB->query($query);
}
function DB_fetch_array($result)
{
- return mysql_fetch_array($result,MYSQL_NUM);
+ if($result)
+ return $result->fetch_array(MYSQLI_NUM);
+ else
+ return NULL;
}
function DB_insert_id()
{
- return mysql_insert_id();
-}
-
-function DB_num_rows($result)
-{
- return mysql_num_rows($result);
+ global $DB;
+ return $DB->insert_id;
}
/* end Mysql functions */
return $result;
}
-function DB_get_passwd_by_name($name)
+function DB_get_version()
{
- $r = DB_query_array("SELECT password FROM User WHERE fullname=".DB_quote_smart($name)."");
-
- if($r)
- return $r[0];
- else
- return "";
+ $version = DB_query_array('SELECT version FROM Version');
+ return $version[0];
}
function DB_get_passwd_by_userid($id)
return $names;
}
+function DB_get_emails_of_last_logins($N)
+{
+ $emails = array();
+
+ $result = DB_query("SELECT email FROM User ORDER BY last_login DESC LIMIT $N");
+ while($r = DB_fetch_array($result))
+ $emails[] = $r[0];
+
+ return $emails;
+}
+
function DB_get_names_of_new_logins($N)
{
$names = array();
return;
}
+function DB_get_game_timestamp($gameid)
+{
+ $r = DB_query_array("SELECT mod_date FROM Game WHERE id=".DB_quote_smart($gameid));
+
+ if($r)
+ return $r[0];
+ else
+ return NULL;
+}
function DB_update_user_timestamp($userid)
{
else
return NULL;
}
+
+function DB_get_user_creation_date($userid)
+{
+ $r = DB_query_array("SELECT create_date FROM User WHERE id=".DB_quote_smart($userid));
+
+ if($r)
+ return $r[0];
+ else
+ return NULL;
+}
+
function DB_get_user_timezone($userid)
{
$r = DB_query_array("SELECT timezone FROM User WHERE id=".DB_quote_smart($userid));
return "Europe/London";
}
-function DB_insert_comment($comment,$playid,$userid)
+function DB_insert_comment($comment,$playid,$gameid,$userid)
{
- DB_query("INSERT INTO Comment VALUES (NULL,NULL,NULL,$userid,$playid, ".DB_quote_smart($comment).")");
+ DB_query("INSERT INTO Comment VALUES (NULL,NULL,NULL,$userid,$playid,$gameid, ".DB_quote_smart($comment).")");
return;
}
+function DB_get_pre_comment($gameid)
+{
+ $r = DB_query_array_all("SELECT comment, User.fullname FROM Comment".
+ " LEFT JOIN User ON User.id=user_id".
+ " WHERE play_id=-1".
+ " AND game_id=$gameid ");
+ return $r;
+}
+
+function DB_get_pre_comment_call($gameid)
+{
+ $r = DB_query_array_all("SELECT comment, User.fullname FROM Comment".
+ " LEFT JOIN User ON User.id=user_id".
+ " WHERE play_id=-2".
+ " AND game_id=$gameid ");
+ return $r;
+}
+
function DB_insert_note($comment,$gameid,$userid)
{
DB_query("INSERT INTO Notes VALUES (NULL,NULL,NULL,$userid,$gameid, ".DB_quote_smart($comment).")");
return $r;
}
-function DB_get_ruleset($dullen,$schweinchen,$call)
+function DB_get_ruleset($dullen,$schweinchen,$call,$lowtrump)
{
$r = array();
$result = DB_query("SELECT id FROM Rulesets WHERE".
" dullen=".DB_quote_smart($dullen)." AND ".
" Rulesets.call=".DB_quote_smart($call)." AND ".
- " schweinchen=".DB_quote_smart($schweinchen));
+ " schweinchen=".DB_quote_smart($schweinchen)." AND ".
+ " lowtrump=".DB_quote_smart($lowtrump));
if($result)
$r = DB_fetch_array($result);
$result = DB_query("INSERT INTO Rulesets VALUES (NULL, NULL, ".
DB_quote_smart($dullen).",".
DB_quote_smart($schweinchen).",".
+ DB_quote_smart($lowtrump).",".
DB_quote_smart($call).
", NULL)");
if($result)
return NULL;
}
+function DB_get_party_by_session_and_userid($session,$userid)
+{
+ /* used in score table by index. gameids are sorted by date, so we need to sort here too! */
+ $r = DB_query_array_all("SELECT party FROM Hand".
+ " LEFT JOIN Game ON Game.id = Hand.game_id".
+ " WHERE Game.session=".DB_quote_smart($session).
+ " AND user_id=".DB_quote_smart($userid)."".
+ " AND Game.status='gameover' ".
+ " ORDER BY Game.create_date ASC");
+ return $r;
+}
+
function DB_set_party_by_hash($hash,$party)
{
DB_query("UPDATE Hand SET party=".DB_quote_smart($party)." WHERE hash=".DB_quote_smart($hash));
/* set defaults */
$PREF['cardset'] = 'english';
$PREF['email'] = 'emailnonaddict';
+ $PREF['digest'] = 'digest-off';
$PREF['autosetup'] = 'no';
$PREF['sorting'] = 'high-low';
$PREF['open_for_games'] = 'yes';
$PREF['vacation_start'] = NULL;
$PREF['vacation_stop'] = NULL;
$PREF['vacation_comment'] = '';
+ $PREF['language'] = 'en';
/* get all preferences */
$r = DB_query('SELECT pref_key, value FROM User_Prefs'.
switch($pref[0])
{
case 'cardset':
- /* licence only valid until then */
- if($pref[1]=="altenburg" && (time()-strtotime( "2009-12-31 23:59:59")<0) )
- $PREF["cardset"]="altenburg";
break;
case 'email':
- if($pref[1]=="emailaddict")
- $PREF["email"]="emailaddict";
+ if($pref[1]=='emailaddict')
+ $PREF['email']='emailaddict';
+ break;
+
+ case 'digest':
+ if($pref[1])
+ $PREF['digest'] = $pref[1];
break;
case 'autosetup':
if($pref[1])
$PREF['vacation_comment'] = $pref[1];
break;
+
+ case 'language':
+ if($pref[1])
+ $PREF['language'] = $pref[1];
+ break;
}
}
+
return $PREF;
}
" LEFT JOIN Game ON Game.ruleset=Rulesets.id ".
" WHERE Game.id='$gameid'" );
- $RULES["dullen"] = $r[2];
- $RULES["schweinchen"] = $r[3];
- $RULES["call"] = $r[4];
+ $RULES['dullen'] = $r[2];
+ $RULES['schweinchen'] = $r[3];
+ $RULES['lowtrump'] = $r[4];
+ $RULES['call'] = $r[5];
return $RULES;
}
return;
}
+function DB_delete_recovery_passwords($userid)
+{
+ DB_query("DELETE FROM Recovery WHERE user_id=".DB_quote_smart($userid));
+ return;
+}
+
function DB_get_card_name($card)
{
if($card==0)
function DB_get_current_playid($gameid)
{
+ /* return playid or -1 for pre-game phase */
$trick = DB_get_max_trickid($gameid);
- if(!$trick) return NULL;
+ if(!$trick) return -1;
$r = DB_query_array("SELECT id FROM Play WHERE trick_id='$trick' ORDER BY create_date DESC LIMIT 1");
if($r)
return $r[0];
- return "";
+ return -1;
}
function DB_get_call_by_hash($hash)
return -1;
}
-function DB_get_score_by_gameid($gameid)
-{
- /* returns the points of a game from the point of the re parth (<0 if they lost) */
- $queryresult = DB_query("SELECT COUNT(*),party FROM Score ".
- " WHERE game_id=$gameid ".
- " GROUP BY party ");
- $re = 0;
- $contra = 0;
-
- while($r = DB_fetch_array($queryresult) )
- {
- if($r[1] == "re")
- $re += $r[0];
- else if ($r[1] == "contra")
- $contra += $r[0];
- };
-
- return ($re - $contra);
-}
-
function DB_get_gameids_of_finished_games_by_session($session)
{
$ids = array ();
if($session==0) /* return all games */
- $queryresult = DB_query("SELECT id FROM Game ".
- " WHERE status='gameover' ".
- " ORDER BY create_date ASC");
+ $queryresult = DB_query_array_all("SELECT Game.id,SUM(IF(STRCMP(Score.party,'re'),-1,1)),Game.type FROM Game ".
+ " LEFT JOIN Score on game_id=Game.id".
+ " WHERE status='gameover' ".
+ " GROUP BY Game.id");
else /* return games in a session */
- $queryresult = DB_query("SELECT id FROM Game ".
- " WHERE session=$session ".
- " AND status='gameover' ".
- " ORDER BY create_date ASC");
+ $queryresult = DB_query_array_all("SELECT Game.id,SUM(IF(STRCMP(Score.party,'re'),-1,1)),Game.type FROM Game ".
+ " LEFT JOIN Score on game_id=Game.id".
+ " WHERE session=$session ".
+ " AND status='gameover' ".
+ " GROUP BY Game.id".
+ " ORDER BY Game.create_date ASC");
- $i=0;
- while($r = DB_fetch_array($queryresult) )
- {
- $ids[$i] = $r[0];
- $i++;
- }
-
- return $ids;
+ return $queryresult;
}
function DB_get_card_value_by_cardid($id)
$r = DB_query_array("SELECT COUNT(winner) FROM Trick Where game_id='$gameid' and winner='$position'");
return $r[0];
}
+
+function DB_digest_insert_email($To,$message,$type,$gameid)
+{
+ if($type == GAME_YOUR_TURN)
+ DB_query("INSERT INTO digest_email VALUES (NULL,".DB_quote_smart($To).",NULL,'your_turn',$gameid,".DB_quote_smart($message).")");
+ else
+ DB_query("INSERT INTO digest_email VALUES (NULL,".DB_quote_smart($To).",NULL,'misc',NULL,".DB_quote_smart($message).")");
+ return;
+}
+
+function DB_get_digest_users()
+{
+ $users = array();
+
+ $result = DB_query("SELECT user_id FROM User_Prefs WHERE pref_key='digest' and value <> 'digest-off'");
+ while($r = DB_fetch_array($result))
+ $users[]=$r[0];
+
+ return $users;
+}
+
+function DB_get_digest_message_by_email($email)
+{
+ $messages = array();
+
+ $result = DB_query("SELECT id,content,type,game_id FROM digest_email Where email='$email'");
+ while($r = DB_fetch_array($result))
+ $messages[]=$r;
+
+ return $messages;
+}
+
+function DB_digest_delete_message($id)
+{
+ DB_query("Delete from digest_email where id='$id'");
+}
+
?>
\ No newline at end of file
projects / e-DoKo.git / blobdiff