$db_name = false;
$db_user = false;
$db_password = false;
+ $db_schema = false;
$content = '';
$thisOption = '';
$requestedView = 'contacts.html';
$db_name = filter_var( $_REQUEST['db_name'], FILTER_SANITIZE_STRING );
$db_user = filter_var( $_REQUEST['db_user'], FILTER_SANITIZE_STRING );
$db_password = filter_var( $_REQUEST['db_password'], FILTER_SANITIZE_STRING );
+ $db_schema = isset($_REQUEST['db_schema']) ? filter_var( $_REQUEST['db_schema'], FILTER_SANITIZE_STRING ) : 'members';
// Connect to the database, if false, we failed, so redisplay form and error message
$error = $this->connectPostgresDb($db_host, $db_name, $db_user, $db_password);
$this->checkContactDelete();
// Do contact import
- $importResult = $this->importContacts();
+ $importResult = $this->importContacts($db_schema);
// Check status and error message
if ($importResult['status'] == false) {
'db_name' => $db_name,
'db_user' => $db_user,
'db_password' => $db_password,
+ 'db_schema' => $db_schema,
'content' => $content,
'thisOption' => $thisOption
);
* @return array Results or false if no contacts to import
*
*/
- public function importContacts()
+ public function importContacts($schema)
{
// Initialize our return status/data array
$sql = "
SELECT member_id, member_name, member_login, member_passwd, process_email,
primary_contact, primary_contact_fname, primary_contact_lname
- FROM members.member
+ FROM $schema.member
WHERE member_login != '';
";
try {