feedc0de/postgresql-for-wordpress
1
0
Fork 0
forked from PostgreSQL-For-Wordpress/postgresql-for-wordpress
Code Pull Requests Activity

remove custom last_insert_ID logic

Browse Source
This commit is contained in:
Matthew Bucci
2024-02-26 23:47:53 -08:00
parent 2d5f178426
commit a2e25163ff
1 changed files with 3 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
pg4wp/driver_pgsql.php
View File

@ -1141,28 +1141,15 @@ function wpsqli_insert_id(&$connection = null)
$data = null; $data = null;
$ins_field = $GLOBALS['pg4wp_ins_field']; $ins_field = $GLOBALS['pg4wp_ins_field'];
$table = $GLOBALS['pg4wp_ins_table']; $table = $GLOBALS['pg4wp_ins_table'];
$lastq = $GLOBALS['pg4wp_last_insert'];
$seq = wpsqli_get_primary_sequence_for_table($connection, $table);
// Special case when using WP_Import plugin where ID is defined in the query itself. if($GLOBALS['pg4wp_ins_id']) {
if($table == $wpdb->term_relationships) {
$sql = 'NO QUERY';
$data = 0;
} elseif ('post_author' == $ins_field && false !== strpos($lastq, 'ID')) {
// No PostgreSQL specific operation here.
$sql = 'ID was in query ';
$pattern = '/.+\'(\d+).+$/';
preg_match($pattern, $lastq, $matches);
$data = $matches[1];
// PostgreSQL: Setting the value of the sequence based on the latest inserted ID.
$GLOBALS['pg4wp_queued_query'] = "SELECT SETVAL('$seq',(SELECT MAX(\"ID\") FROM $table)+1);";
} elseif($GLOBALS['pg4wp_ins_id']) {
return $GLOBALS['pg4wp_ins_id']; return $GLOBALS['pg4wp_ins_id'];
} elseif(empty($sql)) { } elseif(empty($sql)) {
$sql = 'NO QUERY'; $sql = 'NO QUERY';
$data = 0; $data = 0;
} else { } else {
$seq = wpsqli_get_primary_sequence_for_table($connection, $table);
$lastq = $GLOBALS['pg4wp_last_insert'];
// Double quoting is needed to prevent seq from being lowercased automatically // Double quoting is needed to prevent seq from being lowercased automatically
$sql = "SELECT CURRVAL('\"$seq\"')"; $sql = "SELECT CURRVAL('\"$seq\"')";
$res = pg_query($connection, $sql); $res = pg_query($connection, $sql);