connect_error) {
die("Fail1:Failed to connect to MySQL: ". $link->connect_error ."\r\n");
} else {
echo "Conn1:Connection to MySQL \r\n";
}
switch ($Command) {
case "BT":
//Remove // comments if you need to drop the table and start over
//$sql = "Drop TABLE tblSync";
//if ($link->query($sql) === TRUE) {
// echo "Tbl1: Table tblSync dropped \r\n";
//} else {
// echo "Err1: Error dropping table: " . $conn->error."\r\n";
//}
$sql = "CREATE TABLE if not exists tblSync (
Id text, IdFrom text, IdTo text, sType text, sFlag text, sData text )";
echo $sql."\r\n";
if ($link->query($sql) === TRUE) {
echo "Tbl1: Table tblSync created \r\n";
} else {
echo "Err1: Error creating table: " . $conn->error."\r\n";
}
Break;
case "IR":
$sql = "INSERT INTO tblSync ( Id , IdFrom , IdTo , sType, sFlag, sData )
VALUES ('".$Id."','".$IdFrom."','".$IdTo."','".$Type."','0','".$Data."')";
echo $sql."\r\n";
if ($link->query($sql) === TRUE) {
echo "Add1: New record added \r\n";
} else {
echo "Err1: Error: " . $sql . "
" . $conn->error. "\r\n";
}
break;
case "SF":
$sql = "Update tblSync set sFlag='1' where Id='".$Id. "' and IdTo='".$IdTo."' " ;
echo $sql."\r\n";
if ($link->query($sql) === TRUE) {
echo "Set1: Flag set to 1 \r\n";
} else {
echo "Err1: Error: " . $sql . "
" . $conn->error. "\r\n";
}
// now, get the record count
$sql="SELECT count(*) from tblSync where Id='".$Id. "' and IdTo='".$IdTo."' and sFlag='1'";
$count = $link->query($sql)->fetch_row()[0];
echo "Flag1 Records Flagged:" . $count. "\r\n";
break;
case "DR":
$sql = "Delete from tblSync where Id='".$Id. "' and IdTo='".$IdTo."' and sFlag='1' " ;
echo $sql."\r\n";
if ($link->query($sql) === TRUE) {
echo "Del1: Records Deleted \r\n";
} else {
echo "Err1: Error: " . $sql . "
" . $conn->error. "\r\n";
}
break;
case "RR":
$sql = "SELECT * FROM tblSync where Id='".$Id. "' and IdTo='".$IdTo."' and sFlag='1' order by IdFrom, sType" ;
echo $sql."\r\n";
//Run the Query
$result = $link->query($sql);
//If the query returned results, loop through each result
if ($result->num_rows > 0) {
while($row = $result->fetch_assoc()) {
echo "Rec1: " . $row['sType']."".$row['IdFrom']." ". $row['sData']. "\r\n";
}
$result -> free_result();
} else {
echo "0 results \r\n";
}
break;
//End Case
}
// closing connection
$link->close();
echo "Close1:DB Closed";
?>