检查数据库中的条目是否存在 - Drupal 7
Check if the entry in DB exists - Drupal 7
我制作了一个模块,当 cron 运行 时,它从看门狗 table 获取 wid 和变量以及时间戳,并将其传递到一个新的 table blablabla 中。我想如果 blablabla table 中存在具有相同变量的值,则不要传递该值。请遵循我的代码:
function blablabla_cron() {
// Begin building the query.
$query = db_select('watchdog', 'th')
->extend('PagerDefault')
->orderBy('wid')
->fields('th', array('wid', 'timestamp'))
->limit(2000);
// Fetch the result set.
$result = $query -> execute();
// Loop through each item and add to $row.
foreach ($result as $row) {
blablabla_table($row);
}
}
function error_log_jira_table($row) {
$timestamp = $row -> timestamp;
$wid = $row -> wid;
$variables = $row -> variables;
$nid = db_insert('error_log_jira')
->fields(array(
'timestamp' => $timestamp,
'wid' => $wid,
'variables' => $variables
))
->execute();
}
您需要查询 table 以查看数据是否存在,然后再写入数据,如果存在符合条件的行,则什么都不做。例如;
function blablabla_cron() {
// Begin building the query.
$query = db_select('watchdog', 'th')
->extend('PagerDefault')
->orderBy('wid')
->fields('th', array('wid', 'timestamp', 'variables'))
->limit(2000);
// Fetch the result set.
$result = $query -> execute();
// Loop through each item and add to $row.
foreach ($result as $row) {
// Query Blablabla table for row matching timestamp and variables
$r = db_select('blablabla', 'b')
->fields('b')
->condition('timestamp', $row->timestamp, '=')
->condition('variables', $row->variables, '=')
->execute();
// If row doesn't exist then create it (I assume blablabla_table creates?)
if($r->rowCount() == 0) {
blablabla_table($row);
}
}
}
很难给出一个例子,因为您在问题中缺少 blablabla_table()
函数,我假设它写入 blablabla_table。以后问没有占位符名称的问题。
我制作了一个模块,当 cron 运行 时,它从看门狗 table 获取 wid 和变量以及时间戳,并将其传递到一个新的 table blablabla 中。我想如果 blablabla table 中存在具有相同变量的值,则不要传递该值。请遵循我的代码:
function blablabla_cron() {
// Begin building the query.
$query = db_select('watchdog', 'th')
->extend('PagerDefault')
->orderBy('wid')
->fields('th', array('wid', 'timestamp'))
->limit(2000);
// Fetch the result set.
$result = $query -> execute();
// Loop through each item and add to $row.
foreach ($result as $row) {
blablabla_table($row);
}
}
function error_log_jira_table($row) {
$timestamp = $row -> timestamp;
$wid = $row -> wid;
$variables = $row -> variables;
$nid = db_insert('error_log_jira')
->fields(array(
'timestamp' => $timestamp,
'wid' => $wid,
'variables' => $variables
))
->execute();
}
您需要查询 table 以查看数据是否存在,然后再写入数据,如果存在符合条件的行,则什么都不做。例如;
function blablabla_cron() {
// Begin building the query.
$query = db_select('watchdog', 'th')
->extend('PagerDefault')
->orderBy('wid')
->fields('th', array('wid', 'timestamp', 'variables'))
->limit(2000);
// Fetch the result set.
$result = $query -> execute();
// Loop through each item and add to $row.
foreach ($result as $row) {
// Query Blablabla table for row matching timestamp and variables
$r = db_select('blablabla', 'b')
->fields('b')
->condition('timestamp', $row->timestamp, '=')
->condition('variables', $row->variables, '=')
->execute();
// If row doesn't exist then create it (I assume blablabla_table creates?)
if($r->rowCount() == 0) {
blablabla_table($row);
}
}
}
很难给出一个例子,因为您在问题中缺少 blablabla_table()
函数,我假设它写入 blablabla_table。以后问没有占位符名称的问题。