ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / letacommog / entrepro / wp-content / plugins / rh-frontend / includes

<?php

/**
 * A singleton class responsible for interacting with the database.
 *
 * @since 1.0.0
 * @package WPFEPP
 **/
class WPFEPP_DB_Table
{
	/**
	 * A variable initialized with the global $wpdb and used for performing database operations
	 */
	private $db;

/**
	 * Name of the database table
	 */
	private $table_name;

/**
	 * Version of the database table. Changing this number will cause the database table to be dropped and built again.
	 */
	private $db_version;

/**
	 * Class constructor. Initializes all the variables.
	 **/
	public function __construct()
	{
		global $wpdb;
		$this->db = $wpdb;
		$this->table_name = $this->db->prefix ."wpfepp_forms";
		$this->old_table_name = "wpfepp_forms"; // since v.2.3
		$this->db_version = "2.3";
	}

/**
	 * Returns the existing instance of the class. If an instance does not exist, creates and returns a new instance.
	 */
	public static function get_instance() {
		static $instance = null;
		if($instance == null){
			$instance = new WPFEPP_DB_Table();
		}
		return $instance;
	}

/**
	 * Creates the database table. It is also responsible for recreating the table if it is not up-to-date.
	 */
	public function create_table() {
		$current_version = get_option( 'wpfepp_db_table_version' );
		if($current_version && $current_version == $this->db_version && $this->db->get_var("SHOW TABLES LIKE '$this->table_name';") == $this->table_name){
			return;
		}

$charset_collate = $this->db->get_charset_collate();
			$sql = "
				CREATE TABLE $this->table_name (
					id MEDIUMINT(9) NOT NULL AUTO_INCREMENT,
					name TINYTEXT NOT NULL,
					post_type TINYTEXT NOT NULL,
					description TEXT NULL,
					fields LONGTEXT NULL,
					settings LONGTEXT NULL,
					emails LONGTEXT NULL,
					extended LONGTEXT NULL,
					UNIQUE KEY id (id)
				) $charset_collate;
			";
			require_once(ABSPATH . 'wp-admin/includes/upgrade.php');
			dbDelta($sql);
			
		// since v.2.3
		if($this->db->get_var("SHOW TABLES LIKE '$this->old_table_name'") == $this->old_table_name){
			$this->upgrade_new_name_table();
		}
		
		update_option('wpfepp_db_table_version', $this->db_version);
	}

/**
	 * Removes the database table.
	 */
	public function remove_table(){
		$query = "DROP TABLE $this->table_name";
		return $this->db->query($query);
	}

/**
	 * Getter function for the database version variable.
	 */
	public function get_db_version(){
		return $this->db_version;
	}

/**
	 * Adds a new form to the database table.
	 */
	public function add($name, $post_type, $description="", $fields="", $settings="", $emails="", $extended=""){
		return $this->db->insert( $this->table_name, array('name' => $name, 'post_type' => $post_type, 'description' => $description, 'fields' => $this->serialize($fields), 'settings' => $this->serialize($settings), 'emails' => $this->serialize($emails), 'extended' => $this->serialize($extended) ) );
	}

/**
	 * Fetches and returns a row from the database.
	 */
	public function get( $id ){
		$form = $this->db->get_row("SELECT * FROM $this->table_name WHERE id=$id", ARRAY_A);
		if($form){
			$form["fields"] 	= $this->unserialize($form["fields"]);
			$form["settings"] 	= $this->unserialize($form["settings"]);
			$form["emails"] 	= $this->unserialize($form["emails"]);
			$form["extended"] 	= $this->unserialize($form["extended"]);
		}
		return $form;
	}

/**
	*/
	public function get_forms_for_select(){
		$forms = $this->db->get_results("SELECT * FROM $this->table_name", ARRAY_A);
		$rtn_arr = array();
		if(is_array($forms) && count($forms)){
			foreach ($forms as $key => $form) {
				$rtn_arr[$form['id']] = $form['id'] . ' - ' . $form['name'];
			}
		}
		return $rtn_arr;
	}

/**
	 * Fetches and returns the total number of rows in the database table.
	 */
	public function get_total_count(){
		$count = $this->db->get_var("SELECT COUNT(*) FROM $this->table_name");
		return isset($count)?$count:0;
	}

/**
	 * Gets all the rows in a particular range. Used by the list table class for fetching forms on a particular page.
	 */
	public function get_forms($curr_page, $per_page, $post_type = false){
		$start = (($curr_page-1)*$per_page);
		$where = ($post_type) ? "post_type = '$post_type'" : 1;
		$query = "SELECT * FROM $this->table_name WHERE $where ORDER BY id DESC LIMIT $start, $per_page";
		return $this->db->get_results( $query, ARRAY_A );
	}

/**
	 * Deletes single row at once. 
	 */
	public function delete_single( $id ) {
		$query = "DELETE FROM $this->table_name WHERE id = ($id)";
		return $this->db->query( $query );
	}
	
	/**
	 * Deletes multiple rows at once. 
	 */
	public function delete_multiple( $ids ) {
		$id_string = join( ',', $ids );
		$query = "DELETE FROM $this->table_name WHERE id IN ($id_string)";
		return $this->db->query( $query );
	}

/**
	 * Checks if a row exists in the database table.
	 */
	public function form_exists( $id ){
		return $this->db->get_var("SELECT COUNT(*) FROM $this->table_name WHERE id=$id");
	}

/**
	 * Updates the 'fields' column of a particular row.
	 */
	public function update_form_fields($id, $fields){
		return $this->db->update( $this->table_name, array('fields' => $this->serialize($fields)), array('id' => $id) );
	}

/**
	 * Updates the 'settings' column of a particular row.
	 */
	public function update_form_settings($id, $settings){
		return $this->db->update( $this->table_name, array('settings' => $this->serialize($settings)), array('id' => $id) );
	}

public function update_form_emails($id, $emails){
		return $this->db->update( $this->table_name, array('emails' => $this->serialize($emails)), array('id' => $id) );
	}
	
	public function update_form_extended($id, $extended){
		return $this->db->update( $this->table_name, array('extended' => $this->serialize($extended)), array('id' => $id) );
	}

/**
	 * Upgrades all the existing forms in the database to include the new fields and settings offered by the latest plugin version.
	 */
	public function upgrade_forms( $default_fields, $default_settings, $default_emails, $default_extended, $default_custom_field, $post_type ) {
		$forms = $this->get_forms(1, 1000, $post_type);
		if(is_array($forms) && count($forms)){
			foreach ($forms as $key => $form) {
				$form_fields 		= $this->unserialize($form['fields']);
				$form_settings 		= $this->unserialize($form['settings']);
				$form_emails 		= $this->unserialize($form['emails']);
				$form_extended 		= $this->unserialize($form['extended']);
				
				$upgraded_fields 	= wpfepp_update_form_fields($form_fields, $default_fields, $default_custom_field);
				$upgraded_settings 	= wpfepp_update_array($form_settings, $default_settings);
				$upgraded_emails 	= wpfepp_update_array($form_emails, $default_emails);
				$upgraded_extended 	= wpfepp_update_array($form_extended, $default_extended);
				
				$this->db->update( $this->table_name, array('fields' => $this->serialize($upgraded_fields), 'settings' => $this->serialize($upgraded_settings), 'emails' => $this->serialize($upgraded_emails), 'extended' => $this->serialize($upgraded_extended)), array('id' => $form['id']) );
			}
		}
	}

private function serialize($item){
		return base64_encode(serialize($item));
	}

private function unserialize($item){
		if(base64_decode($item, true) !== false)
			$item = base64_decode($item);

return unserialize($item);
	}

public function delete_post_meta( $meta_key ) {
		$table = $this->db->postmeta;
		return $this->db->query("DELETE FROM $table WHERE meta_key = $meta_key");
	}

/**
	 * Removes old table and moves its data into renamed one
	 *
	 * @since v.2.3
	 **/
	public function upgrade_new_name_table(){
		$copy_query = "INSERT INTO $this->table_name SELECT * FROM $this->old_table_name";
		$this->db->query($copy_query);
		$delete_query = "DROP TABLE $this->old_table_name";
		$this->db->query($delete_query);
	}
	
	/**
	 * Export forms from Database to JSON file 
	 **/
	public function export_tables_to_json() {
		$results = array();
		
	   if ( ob_get_contents() )
			ob_clean();

$query = "SELECT * FROM {$this->table_name}";
		$results = $this->db->get_results( $query, OBJECT );
			
		if( $results ){
			$json = json_encode( $results );
			echo $json;
		}else{
			echo $wpdb->last_error;
		}
		die();
	}
	
	/**
	 * Import forms to Database from JSON file 
	 **/	
	 public function import_tables_from_json( $path_to_file = '' ) {
		 $admin_notice = 0;
			
		if( $this->db->get_var("SHOW TABLES LIKE '$this->table_name';") != $this->table_name )
			return;

$responce = $this->db->query( "TRUNCATE {$this->table_name};" );
		
		if( $responce && !empty( $path_to_file ) ) {
			$json_data = json_decode( file_get_contents( $path_to_file ), true );
			foreach( $json_data as $id => $row ){
				$insert_pairs = array();
				foreach( $row as $key => $val ) {
					$insert_pairs[addslashes( $key )] = addslashes( $val );
				}
				$insert_keys = '`' . implode( '`,`', array_keys( $insert_pairs ) ) . '`';
				$insert_vals = '"' . implode( '","', array_values( $insert_pairs ) ) . '"';
				$this->db->query( "INSERT INTO `{$this->table_name}` ({$insert_keys}) VALUES ({$insert_vals});" );
			}
			$admin_notice = 1;
		}
		return $admin_notice;
	}
}

[+] ..
[-] class-wpfepp-loader.php [edit]
[-] class-update-checker.php [edit]
[-] class-wpfepp-copyscape.php [edit]
[-] class-wpfepp-post-previews.php [edit]
[-] paid-functions.php [edit]
[-] class-wpfepp-captcha.php [edit]
[-] class-wpfepp-form-ajax.php [edit]
[-] class-wpfepp-db-table.php [edit]
[-] class-wpfepp-wc-package.php [edit]
[+] partials
[-] class-wpfepp-image.php [edit]
[-] class-wpfepp-shortcode-manager.php [edit]
[-] class-wpfepp-post-list.php [edit]
[-] class-wpfepp-helpers.php [edit]
[-] class-frontend-publishing-pro.php [edit]
[-] global-functions.php [edit]
[-] class-wpfepp-email-manager.php [edit]
[-] hook-functions.php [edit]
[-] class-wpfepp-form.php [edit]