X-Git-Url: http://git.pjr.cc/?p=gwvp.git;a=blobdiff_plain;f=gwvplib%2Fgwvpdatabase.php;fp=gwvplib%2Fgwvpdatabase.php;h=065b406ac67a1958ade94f72800e0da4f0961ca3;hp=a79adb0eb360f210d4e70b3e41d9b1f0f194ec16;hb=760357457c7b3997bd8a488eb74180463731ddfa;hpb=74399e0d5226d43656c618451b4e6fc06702e5ab

diff --git a/gwvplib/gwvpdatabase.php b/gwvplib/gwvpdatabase.php
index a79adb0..065b406 100644
--- a/gwvplib/gwvpdatabase.php
+++ b/gwvplib/gwvpdatabase.php
@@ -79,6 +79,14 @@ function gwvp_dbCreateSQLiteStructure($dbloc)
 	$DB_CONNECTION->query($groupmemsql);
 }
 
+function gwvp_forceDisconnect()
+{
+	
+	global $DB_CONNECTION;
+	
+	$DB_CONNECTION = false;
+}
+
 function gwvp_isDBSetup()
 {
 	// for sqlite, we just check if the db exists, for everyone else, we check for a conneciton and go yay or nay
@@ -442,6 +450,44 @@ function gwvp_getUserEmail($id)
 	return $return;
 }
 
+function gwvp_deleteGroupMemberByID($uid, $gid)
+{
+	$conn = gwvp_ConnectDB();
+
+	/*
+	 * 		CREATE TABLE "group_membership" (
+	 "groupmember_id" INTEGER PRIMARY KEY AUTOINCREMENT,
+	 "groupmember_groupid" INTEGER,
+	 "groupmember_userid" INTEGER
+
+	 */
+	$sql = "delete from group_membership where groupmember_groupid='$gid' and  groupmember_userid='$uid'";
+
+	$conn->query($sql);
+
+	return true;
+}
+
+
+function gwvp_addGroupMemberByID($uid, $gid)
+{
+	$conn = gwvp_ConnectDB();
+
+	/*
+	 * 		CREATE TABLE "group_membership" (
+	 "groupmember_id" INTEGER PRIMARY KEY AUTOINCREMENT,
+	 "groupmember_groupid" INTEGER,
+	 "groupmember_userid" INTEGER
+
+	 */
+	$sql = "insert into group_membership values (null, '$gid', '$uid')";
+
+	$conn->query($sql);
+
+	return true;
+}
+
+
 function gwvp_addGroupMember($email, $groupname)
 {
 	$conn = gwvp_ConnectDB();
@@ -456,7 +502,7 @@ function gwvp_addGroupMember($email, $groupname)
 	 "groupmember_userid" INTEGER
 
 	 */
-	if($uid!=false&&$gid!=false) $sql = "insert into group_membership values (null, '$gid', '$uid')";
+	if($uid!=false&&$gid!=false) gwvp_addGroupMemberByID($uid, $gid);
 	else return false;
 
 	$conn->query($sql);