Edit File by line

<?php

[0] Fix | Delete

class NF_Database_FieldsController

[1] Fix | Delete

{

[2] Fix | Delete

private $db;

[3] Fix | Delete

private $form_id;

[4] Fix | Delete

private $fields_data;

[5] Fix | Delete

private $new_field_ids;

[6] Fix | Delete

private $insert_fields;

[7] Fix | Delete

private $insert_field_meta = array();

[8] Fix | Delete

private $insert_field_meta_chunk = 0;

[9] Fix | Delete

/**

[10] Fix | Delete

* An array of UPDATE SQL strings.

[11] Fix | Delete

[12] Fix | Delete

* i.e. array( 'key' => 'WHERE `id` = X THEN...' )

[13] Fix | Delete

[14] Fix | Delete

* @var array

[15] Fix | Delete

[16] Fix | Delete

private $update_fields = array(

[17] Fix | Delete

'id' => '',

[18] Fix | Delete

'key' => '',

[19] Fix | Delete

'label' => '',

[20] Fix | Delete

'type' => '',

[21] Fix | Delete

'field_key' => '',

[22] Fix | Delete

'field_label' => '',

[23] Fix | Delete

'order' => '',

[24] Fix | Delete

'default_value' => '',

[25] Fix | Delete

'label_pos' => '',

[26] Fix | Delete

'required' => '',

[27] Fix | Delete

'personally_identifiable' => '',

[28] Fix | Delete

);

[29] Fix | Delete

private $update_field_meta = array();

[30] Fix | Delete

private $update_field_meta_chunk = 0;

[31] Fix | Delete

[32] Fix | Delete

private $db_stage_1_complete = true;

[33] Fix | Delete

[34] Fix | Delete

/**

[35] Fix | Delete

* Store an array of columns that we want to store in our table rather than meta.

[36] Fix | Delete

[37] Fix | Delete

* This array stores the column name and the name of the setting that it maps to.

[38] Fix | Delete

[39] Fix | Delete

* The format is:

[40] Fix | Delete

[41] Fix | Delete

* array( 'COLUMN_NAME' => 'SETTING_NAME' )

[42] Fix | Delete

[43] Fix | Delete

private $db_columns = array(

[44] Fix | Delete

'parent_id' => 'parent_id',

[45] Fix | Delete

'id' => 'id',

[46] Fix | Delete

'key' => 'key',

[47] Fix | Delete

'type' => 'type',

[48] Fix | Delete

'label' => 'label',

[49] Fix | Delete

'field_key' => 'key',

[50] Fix | Delete

'field_label' => 'label',

[51] Fix | Delete

'order' => 'order',

[52] Fix | Delete

'required' => 'required',

[53] Fix | Delete

'default_value' => 'default',

[54] Fix | Delete

'label_pos' => 'label_pos',

[55] Fix | Delete

'personally_identifiable' => 'personally_identifiable',

[56] Fix | Delete

);

[57] Fix | Delete

[58] Fix | Delete

private $db_bit_columns = array(

[59] Fix | Delete

'required',

[60] Fix | Delete

'personally_identifiable',

[61] Fix | Delete

);

[62] Fix | Delete

[63] Fix | Delete

public function __construct( $form_id, $fields_data )

[64] Fix | Delete

{

[65] Fix | Delete

global $wpdb;

[66] Fix | Delete

$this->db = $wpdb;

[67] Fix | Delete

$this->form_id = $form_id;

[68] Fix | Delete

$this->fields_data = $fields_data;

[69] Fix | Delete

[70] Fix | Delete

/**

[71] Fix | Delete

* Remove new DB columns from our $db_columns list if the user hasn't completed required upgrades stage 1.

[72] Fix | Delete

[73] Fix | Delete

$sql = "SHOW COLUMNS FROM {$this->db->prefix}nf3_fields LIKE 'field_key'";

[74] Fix | Delete

$results = $this->db->get_results( $sql );

[75] Fix | Delete

/**

[76] Fix | Delete

* If we don't have the field_key column, we need to remove our new columns.

[77] Fix | Delete

[78] Fix | Delete

* Also, set our db stage 1 tracker to false.

[79] Fix | Delete

[80] Fix | Delete

if ( empty ( $results ) ) {

[81] Fix | Delete

unset( $this->db_columns[ 'field_key' ] );

[82] Fix | Delete

unset( $this->db_columns[ 'field_label' ] );

[83] Fix | Delete

unset( $this->db_columns[ 'order' ] );

[84] Fix | Delete

unset( $this->db_columns[ 'required' ] );

[85] Fix | Delete

unset( $this->db_columns[ 'default_value' ] );

[86] Fix | Delete

unset( $this->db_columns[ 'label_pos' ] );

[87] Fix | Delete

unset( $this->db_columns[ 'personally_identifiable' ] );

[88] Fix | Delete

[89] Fix | Delete

$this->db_stage_1_complete = false;

[90] Fix | Delete

}

[91] Fix | Delete

}

[92] Fix | Delete

public function run()

[93] Fix | Delete

{

[94] Fix | Delete

$this->db->hide_errors();

[95] Fix | Delete

[96] Fix | Delete

/* FIELDS */

[97] Fix | Delete

$this->parse_fields();

[98] Fix | Delete

[99] Fix | Delete

$insert_fields_query = $this->get_insert_fields_query();

[100] Fix | Delete

if( ! empty( $insert_fields_query ) ){

[101] Fix | Delete

$this->db->query( $insert_fields_query );

[102] Fix | Delete

$this->update_new_field_ids();

[103] Fix | Delete

}

[104] Fix | Delete

[105] Fix | Delete

$update_fields_query = $this->get_update_fields_query();

[106] Fix | Delete

if( ! empty( $update_fields_query ) ){

[107] Fix | Delete

$this->db->query( $update_fields_query );

[108] Fix | Delete

}

[109] Fix | Delete

[110] Fix | Delete

/* FIELD META */

[111] Fix | Delete

$this->parse_field_meta();

[112] Fix | Delete

$this->run_insert_field_meta_query();

[113] Fix | Delete

$this->run_update_field_meta_query();

[114] Fix | Delete

[115] Fix | Delete

//Set IDs to repeater child fields if needed

[116] Fix | Delete

$this->check_update_new_repeater_field_ids();

[117] Fix | Delete

[118] Fix | Delete

}

[119] Fix | Delete

public function get_updated_fields_data()

[120] Fix | Delete

{

[121] Fix | Delete

return $this->fields_data;

[122] Fix | Delete

}

[123] Fix | Delete

private function parse_fields()

[124] Fix | Delete

{

[125] Fix | Delete

foreach( $this->fields_data as $field_data ){

[126] Fix | Delete

$field_id = $field_data[ 'id' ];

[127] Fix | Delete

[128] Fix | Delete

/**

[129] Fix | Delete

* We've defined which items go into our DB, as well as which settings they map to.

[130] Fix | Delete

[131] Fix | Delete

* Loop over our $db_columns array and setup an array for $settings.

[132] Fix | Delete

[133] Fix | Delete

$settings = array();

[134] Fix | Delete

[135] Fix | Delete

foreach( $this->db_columns as $column_name => $setting_name ) {

[136] Fix | Delete

$value = '';

[137] Fix | Delete

if( isset( $field_data[ 'settings' ][ $setting_name ] ) ) {

[138] Fix | Delete

// If the setting value is numeric, make sure it's intval'd.

[139] Fix | Delete

if ( is_numeric( $field_data[ 'settings' ][ $setting_name ] ) ) {

[140] Fix | Delete

$value = intval( $field_data[ 'settings' ][ $setting_name ] );

[141] Fix | Delete

} else {

[142] Fix | Delete

$value = $field_data[ 'settings' ][ $setting_name ];

[143] Fix | Delete

}

[144] Fix | Delete

}

[145] Fix | Delete

[146] Fix | Delete

if ( in_array( $column_name, $this->db_bit_columns ) ) {

[147] Fix | Delete

$value = absint( $value );

[148] Fix | Delete

}

[149] Fix | Delete

[150] Fix | Delete

$settings[ $column_name ] = $value;

[151] Fix | Delete

}

[152] Fix | Delete

[153] Fix | Delete

/**

[154] Fix | Delete

* We need to decide if we need to insert this field or update it in our fields table.

[155] Fix | Delete

[156] Fix | Delete

* If we don't have a numeric field id, we're dealing with a tmp field, which is a new field

[157] Fix | Delete

[158] Fix | Delete

* If this field exists in our cache, but doesn't exist in our table, we need to insert it.

[159] Fix | Delete

[160] Fix | Delete

* Otherwise, we're updating.

[161] Fix | Delete

[162] Fix | Delete

* Check our DB for a field with this id.

[163] Fix | Delete

[164] Fix | Delete

if ( is_numeric( $field_id ) ) {

[165] Fix | Delete

$field_in_db = $this->db->get_row( "SELECT `id` FROM `{$this->db->prefix}nf3_fields` WHERE `id` = {$field_id}" );

[166] Fix | Delete

} else {

[167] Fix | Delete

$field_in_db = array();

[168] Fix | Delete

}

[169] Fix | Delete

[170] Fix | Delete

/**

[171] Fix | Delete

* If $field_id isn't a number, then it's a tmp-id.

[172] Fix | Delete

[173] Fix | Delete

* If we have a tmp-id OR the field hasn't been found in our DB, we need to insert it.

[174] Fix | Delete

[175] Fix | Delete

if( ! is_numeric( $field_id ) || empty( $field_in_db ) ) {

[176] Fix | Delete

[177] Fix | Delete

/**

[178] Fix | Delete

* If our $field_id is numeric, we want to insert it into the db with the row.

[179] Fix | Delete

[180] Fix | Delete

* If it's not, we want to pass NULL so that we get an autoincrement.

[181] Fix | Delete

[182] Fix | Delete

if ( is_numeric( $field_id ) ) {

[183] Fix | Delete

$settings[ 'id' ] = $field_id;

[184] Fix | Delete

} else {

[185] Fix | Delete

$settings[ 'id' ] = NULL;

[186] Fix | Delete

}

[187] Fix | Delete

// New Field.

[188] Fix | Delete

$this->insert_field( $settings );

[189] Fix | Delete

} else {

[190] Fix | Delete

// We're updating field settings.

[191] Fix | Delete

$this->update_field( $field_id, $settings );

[192] Fix | Delete

}

[193] Fix | Delete

}

[194] Fix | Delete

}

[195] Fix | Delete

[196] Fix | Delete

private function parse_field_meta()

[197] Fix | Delete

{

[198] Fix | Delete

// collect sanitized data to rewrite class property $this->fields_data

[199] Fix | Delete

$updatedFieldsData=[];

[200] Fix | Delete

[201] Fix | Delete

$existing_meta = $this->get_existing_meta();

[202] Fix | Delete

[203] Fix | Delete

foreach( $this->fields_data as $field_data ){

[204] Fix | Delete

[205] Fix | Delete

$field_id = $field_data[ 'id' ];

[206] Fix | Delete

[207] Fix | Delete

foreach( $field_data[ 'settings' ] as $key => $value ){

[208] Fix | Delete

[209] Fix | Delete

//Sanitize string settings if disallow_unfiltered_html is true

[210] Fix | Delete

if(is_string($value) && WPN_Helper::maybe_disallow_unfiltered_html_for_sanitization()){

[211] Fix | Delete

$field_data[ 'settings' ][$key] = WPN_Helper::sanitize_string_setting_value($key, $value);

[212] Fix | Delete

}

[213] Fix | Delete

[214] Fix | Delete

// we don't need object type or domain stored in the db

[215] Fix | Delete

if( ! in_array( $key, array( 'objectType', 'objectDomain' ) ) ) {

[216] Fix | Delete

if( isset( $existing_meta[ $field_id ][ $key ] ) ){

[217] Fix | Delete

if( $value == $existing_meta[ $field_id ][ $key ] && $value == $existing_meta[ $field_id ][ 'meta_key' ][ $key ] ) continue;

[218] Fix | Delete

$this->update_field_meta( $field_id, $key, $value );

[219] Fix | Delete

} else {

[220] Fix | Delete

$this->insert_field_meta( $field_id, $key, $value );

[221] Fix | Delete

}

[222] Fix | Delete

}

[223] Fix | Delete

}

[224] Fix | Delete

[225] Fix | Delete

// Add field_data to updated collection

[226] Fix | Delete

$updatedFieldsData[]=$field_data;

[227] Fix | Delete

}

[228] Fix | Delete

[229] Fix | Delete

// Rewrite the collection with the updated fields_data collection

[230] Fix | Delete

$this->fields_data = $updatedFieldsData;

[231] Fix | Delete

}

[232] Fix | Delete

[233] Fix | Delete

private function get_existing_meta()

[234] Fix | Delete

{

[235] Fix | Delete

[236] Fix | Delete

$sql_select = "m.parent_id, m.key, m.value";

[237] Fix | Delete

[238] Fix | Delete

/**

[239] Fix | Delete

* If we have completed stage 1 of our db migration, pull meta_key and meta_value as well as key and value.

[240] Fix | Delete

[241] Fix | Delete

if ( $this->db_stage_1_complete ) {

[242] Fix | Delete

$sql_select .= " , m.meta_key, m.meta_value";

[243] Fix | Delete

}

[244] Fix | Delete

[245] Fix | Delete

$results = $this->db->get_results("

[246] Fix | Delete

SELECT {$sql_select}

[247] Fix | Delete

FROM `{$this->db->prefix}nf3_field_meta` AS m

[248] Fix | Delete

LEFT JOIN `{$this->db->prefix}nf3_fields` AS f

[249] Fix | Delete

ON m.parent_id = f.id

[250] Fix | Delete

WHERE f.parent_id = {$this->form_id}

[251] Fix | Delete

");

[252] Fix | Delete

$field_meta = array();

[253] Fix | Delete

foreach( $results as $meta ){

[254] Fix | Delete

$meta_value = '';

[255] Fix | Delete

if( ! isset( $field_meta[ $meta->parent_id ] ) ) $field_meta[ $meta->parent_id ] = array();

[256] Fix | Delete

$field_meta[ $meta->parent_id ][ $meta->key ] = $meta->value;

[257] Fix | Delete

if ( property_exists( $meta, 'meta_value' ) ) {

[258] Fix | Delete

if ( ! is_null( $meta->meta_value ) ) {

[259] Fix | Delete

$meta_value = $meta->meta_value;

[260] Fix | Delete

}

[261] Fix | Delete

}

[262] Fix | Delete

$field_meta[ $meta->parent_id ]['meta_key'][ $meta->key ] = $meta_value;

[263] Fix | Delete

}

[264] Fix | Delete

return $field_meta;

[265] Fix | Delete

}

[266] Fix | Delete

private function update_new_field_ids()

[267] Fix | Delete

{

[268] Fix | Delete

$field_id_lookup = $this->db->get_results("

[269] Fix | Delete

SELECT `key`, `id`

[270] Fix | Delete

FROM {$this->db->prefix}nf3_fields

[271] Fix | Delete

WHERE `parent_id` = {$this->form_id}

[272] Fix | Delete

", OBJECT_K);

[273] Fix | Delete

foreach( $this->fields_data as $i => $field_data ){

[274] Fix | Delete

$field_key = $field_data[ 'settings' ][ 'key' ];

[275] Fix | Delete

if( ! is_numeric( $field_data[ 'id' ] ) && isset( $field_id_lookup[ $field_key ] ) ){

[276] Fix | Delete

$tmp_id = $field_data[ 'id' ];

[277] Fix | Delete

$this->fields_data[ $i ][ 'id' ] = $this->new_field_ids[ $tmp_id ] = $field_id_lookup[ $field_key ]->id;

[278] Fix | Delete

}

[279] Fix | Delete

}

[280] Fix | Delete

}

[281] Fix | Delete

//Check IDs stored for each repeater fields, if a temporary ID is detected we'll assign an ID based on the higher value amongst other ID values.

[282] Fix | Delete

private function check_update_new_repeater_field_ids()

[283] Fix | Delete

{

[284] Fix | Delete

foreach( $this->fields_data as $index => $field_data ){

[285] Fix | Delete

if( $field_data['settings']['type'] === "repeater" && !empty($field_data['settings']['fields']) ){

[286] Fix | Delete

$field_id_lookup = [];

[287] Fix | Delete

//build an array of IDs that are not temporary and extract the suffix ( we will check for the higher suffix to set new IDs )

[288] Fix | Delete

foreach( $field_data['settings']['fields'] as $field ) {

[289] Fix | Delete

if(is_numeric($field['id']) && strpos((string)$field['id'], ".") !== false){

[290] Fix | Delete

$child_id = str_replace( (string)$field_data['id'] . '.', '', (string)$field['id']);

[291] Fix | Delete

$field_id_lookup[] = $child_id;

[292] Fix | Delete

}

[293] Fix | Delete

}

[294] Fix | Delete

//Size of the array of IDs

[295] Fix | Delete

$n = sizeof($field_id_lookup);

[296] Fix | Delete

//Default Higher value for comparison

[297] Fix | Delete

$higher = 0;

[298] Fix | Delete

//Compare each suffix values and keep the higher to define $higher.

[299] Fix | Delete

for ($l = 0; $l < $n; $l++) {

[300] Fix | Delete

$higher = $field_id_lookup[$l] > $higher ? $field_id_lookup[$l] : $higher;

[301] Fix | Delete

}

[302] Fix | Delete

//Loop through repeater fields to save a fixed ID if temp ID detected

[303] Fix | Delete

foreach( $field_data['settings']['fields'] as $i => $field ) {

[304] Fix | Delete

//If temp ID increment 1 above the higher ID stored

[305] Fix | Delete

if(!is_numeric($field["id"]) || strpos((string)$field['id'], ".") === false){

[306] Fix | Delete

$higher = (int)$higher + 1;

[307] Fix | Delete

$repeater_child_tmp_id = $field["id"];

[308] Fix | Delete

$new_repeater_child_id = $field_data['id'] . '.' . $higher;

[309] Fix | Delete

//Set new ID in the repater field collection and new_ids to update

[310] Fix | Delete

$this->fields_data[$index]['settings']['fields'][$i]['id'] = $this->new_field_ids[ $repeater_child_tmp_id ] = $new_repeater_child_id;

[311] Fix | Delete

}

[312] Fix | Delete

}

[313] Fix | Delete

}

[314] Fix | Delete

}

[315] Fix | Delete

}

[316] Fix | Delete

[317] Fix | Delete

public function get_new_field_ids()

[318] Fix | Delete

{

[319] Fix | Delete

return $this->new_field_ids;

[320] Fix | Delete

}

[321] Fix | Delete

[322] Fix | Delete

|--------------------------------------------------------------------------

[323] Fix | Delete

| INSERT (NEW) FIELDS

[324] Fix | Delete

|--------------------------------------------------------------------------

[325] Fix | Delete

[326] Fix | Delete

private function insert_field( $settings )

[327] Fix | Delete

{

[328] Fix | Delete

// Add our initial opening parenthesis.

[329] Fix | Delete

$this->insert_fields .= "(";

[330] Fix | Delete

// Add our form id to our settings as 'parent_id'.

[331] Fix | Delete

$settings[ 'parent_id' ] = $this->form_id;

[332] Fix | Delete

[333] Fix | Delete

/**

[334] Fix | Delete

* Loop over each of our $this->db_columns to create a value list for our SQL statement.

[335] Fix | Delete

[336] Fix | Delete

foreach ( $this->db_columns as $column_name => $setting_name ) {

[337] Fix | Delete

[338] Fix | Delete

$value = $settings[ $column_name ];

[339] Fix | Delete

[340] Fix | Delete

// For new fields, specify the `id` as NULL for insert.

[341] Fix | Delete

if('id' == $column_name && is_null($value)){

[342] Fix | Delete

$this->insert_fields .= "NULL,";

[343] Fix | Delete

continue;

[344] Fix | Delete

}

[345] Fix | Delete

[346] Fix | Delete

$this->db->escape_by_ref( $value );

[347] Fix | Delete

if ( is_numeric( $value ) ) {

[348] Fix | Delete

$this->insert_fields .= "{$value},";

[349] Fix | Delete

} else {

[350] Fix | Delete

$this->insert_fields .= "'{$value}',";

[351] Fix | Delete

}

[352] Fix | Delete

[353] Fix | Delete

}

[354] Fix | Delete

// Remove any trailing commas from our SQL string.

[355] Fix | Delete

$this->insert_fields = rtrim( $this->insert_fields, ',' );

[356] Fix | Delete

$this->insert_fields .= '),';

[357] Fix | Delete

}

[358] Fix | Delete

public function get_insert_fields_query()

[359] Fix | Delete

{

[360] Fix | Delete

if( ! $this->insert_fields ) return "";

[361] Fix | Delete

$insert_fields = rtrim( $this->insert_fields, ',' ); // Strip trailing comma from SQl.

[362] Fix | Delete

[363] Fix | Delete

/**

[364] Fix | Delete

* Loop over each of our $this->db_columns to create a column list for our SQL statement below.

[365] Fix | Delete

[366] Fix | Delete

$columns = '';

[367] Fix | Delete

foreach( $this->db_columns as $column_name => $setting_name ) {

[368] Fix | Delete

$columns .= "`{$column_name}` ,";

[369] Fix | Delete

}

[370] Fix | Delete

[371] Fix | Delete

$columns = rtrim( $columns, ',' );

[372] Fix | Delete

[373] Fix | Delete

return "

[374] Fix | Delete

INSERT INTO {$this->db->prefix}nf3_fields ( {$columns} )

[375] Fix | Delete

VALUES {$insert_fields}

[376] Fix | Delete

[377] Fix | Delete

}

[378] Fix | Delete

[379] Fix | Delete

|--------------------------------------------------------------------------

[380] Fix | Delete

| UPDATE (EXISTING) FIELDS

[381] Fix | Delete

|--------------------------------------------------------------------------

[382] Fix | Delete

[383] Fix | Delete

private function update_field( $field_id, $settings )

[384] Fix | Delete

{

[385] Fix | Delete

foreach ( $settings as $setting => $value ) {

[386] Fix | Delete

$line = "WHEN `id` = '{$field_id}' ";

[387] Fix | Delete

$this->db->escape_by_ref( $value );

[388] Fix | Delete

$line .= "THEN ";

[389] Fix | Delete

if ( is_numeric( $value ) ) {

[390] Fix | Delete

$line .= "{$value} ";

[391] Fix | Delete

} else {

[392] Fix | Delete

$line .= "'{$value}' ";

[393] Fix | Delete

}

[394] Fix | Delete

[395] Fix | Delete

if( isset( $this->update_fields[ $setting ] ) ) {

[396] Fix | Delete

$this->update_fields[ $setting ] .= $line;

[397] Fix | Delete

} else {

[398] Fix | Delete

$this->update_fields[ $setting ] = $line;

[399] Fix | Delete

}

[400] Fix | Delete

}

[401] Fix | Delete

}

[402] Fix | Delete

public function get_update_fields_query()

[403] Fix | Delete

{

[404] Fix | Delete

/**

[405] Fix | Delete

* Loop over our $db_columns class var and make sure that none of them are empty.

[406] Fix | Delete

[407] Fix | Delete

* If they are empty, return an empty string to prevent errors.

[408] Fix | Delete

[409] Fix | Delete

[410] Fix | Delete

foreach ( $this->db_columns as $column_name => $setting_name ) {

[411] Fix | Delete

if ( empty( $this->update_fields[ $column_name ] ) ) {

[412] Fix | Delete

return "";

[413] Fix | Delete

}

[414] Fix | Delete

}

[415] Fix | Delete

[416] Fix | Delete

/**

[417] Fix | Delete

* Build our return statement based upon our $db_columns class var.

[418] Fix | Delete

[419] Fix | Delete

[420] Fix | Delete

$return = "UPDATE {$this->db->prefix}nf3_fields

[421] Fix | Delete

SET ";

[422] Fix | Delete

[423] Fix | Delete

foreach( $this->db_columns as $column_name => $setting_name ) {

[424] Fix | Delete

// We don't need to update our parent_id or our id.

[425] Fix | Delete

if ( 'id' == $column_name || 'parent_id' == $column_name ) {

[426] Fix | Delete

continue;

[427] Fix | Delete

}

[428] Fix | Delete

$return .= "`{$column_name}` = CASE {$this->update_fields[ $column_name ]}

[429] Fix | Delete

ELSE `{$column_name}`

[430] Fix | Delete

END

[431] Fix | Delete

,";

[432] Fix | Delete

}

[433] Fix | Delete

[434] Fix | Delete

$return = rtrim( $return, ',' );

[435] Fix | Delete

return $return;

[436] Fix | Delete

}

[437] Fix | Delete

[438] Fix | Delete

|--------------------------------------------------------------------------

[439] Fix | Delete

| INSERT (NEW) META

[440] Fix | Delete

|--------------------------------------------------------------------------

[441] Fix | Delete

[442] Fix | Delete

private function insert_field_meta( $field_id, $key, $value )

[443] Fix | Delete

{

[444] Fix | Delete

static $counter;

[445] Fix | Delete

[446] Fix | Delete

$value = maybe_serialize( $value );

[447] Fix | Delete

[448] Fix | Delete

$this->db->escape_by_ref( $field_id );

[449] Fix | Delete

$this->db->escape_by_ref( $key );

[450] Fix | Delete

$this->db->escape_by_ref( $value );

[451] Fix | Delete

[452] Fix | Delete

if( ! isset( $this->insert_field_meta[ $this->insert_field_meta_chunk ] ) || ! $this->insert_field_meta[ $this->insert_field_meta_chunk ] ) {

[453] Fix | Delete

$this->insert_field_meta[ $this->insert_field_meta_chunk ] = '';

[454] Fix | Delete

}

[455] Fix | Delete

[456] Fix | Delete

$insert_values = "'{$field_id}','{$key}','{$value}'";

[457] Fix | Delete

[458] Fix | Delete

/**

[459] Fix | Delete

* If we have completed stage 1 of our db update process, then we want to add meta_key and meta_value as well as key and value.

[460] Fix | Delete

[461] Fix | Delete

if ( $this->db_stage_1_complete ) {

[462] Fix | Delete

$insert_values .= ", '{$key}','{$value}'";

[463] Fix | Delete

}

[464] Fix | Delete

[465] Fix | Delete

$this->insert_field_meta[ $this->insert_field_meta_chunk ] .= "( {$insert_values} ),";

[466] Fix | Delete

[467] Fix | Delete

$counter++;

[468] Fix | Delete

if( 0 == $counter % 5000 ) $this->insert_field_meta_chunk++;

[469] Fix | Delete

}

[470] Fix | Delete

[471] Fix | Delete

public function run_insert_field_meta_query()

[472] Fix | Delete

{

[473] Fix | Delete

if( ! $this->insert_field_meta ) return "";

[474] Fix | Delete

foreach( $this->insert_field_meta as $insert_field_meta ){

[475] Fix | Delete

$insert_field_meta = rtrim( $insert_field_meta, ',' ); // Strip trailing comma from SQl.

[476] Fix | Delete

[477] Fix | Delete

/**

[478] Fix | Delete

* If we have completed stage 1 of our db update process, then we want to insert meta_key and meta_value as well.

[479] Fix | Delete

[480] Fix | Delete

$insert_columns = '`parent_id`, `key`, `value`';

[481] Fix | Delete

if ( $this->db_stage_1_complete ) {

[482] Fix | Delete

$insert_columns .= ', `meta_key`, `meta_value`';

[483] Fix | Delete

}

[484] Fix | Delete

[485] Fix | Delete

$this->db->query( "

[486] Fix | Delete

INSERT INTO {$this->db->prefix}nf3_field_meta ( {$insert_columns} )

[487] Fix | Delete

VALUES {$insert_field_meta}

[488] Fix | Delete

");

[489] Fix | Delete

}

[490] Fix | Delete

}

[491] Fix | Delete

[492] Fix | Delete

|--------------------------------------------------------------------------

[493] Fix | Delete

| UPDATE (EXISTING) META

[494] Fix | Delete

|--------------------------------------------------------------------------

[495] Fix | Delete

[496] Fix | Delete

private function update_field_meta( $field_id, $key, $value )

[497] Fix | Delete

{

[498] Fix | Delete

static $counter;

[499] Fix | Delete