let value1 = "pk";
let value2 = "bxr";
const mysql = require('mysql2/promise');
const pool = mysql.createPool({
host: 'localhost',
user: 'root',
password: 'root@123',
database: 'abc'
});
// perform the check for duplicates using a prepared statement
async function checkForDuplicates() {
const conn = await pool.getConnection();
try {
const [rows, fields] = await conn.query("SELECT COUNT(*) FROM users WHERE name = ? AND address = ?", [value1, value2]);
if (rows[0]["COUNT(*)"] == 0) {
// no duplicates found, so insert the data into the table
await conn.query("INSERT INTO users (name, address) VALUES (?, ?)", [value1, value2]);
console.log("Data inserted successfully");
} else {
// duplicates found, so show an error message
console.log("Duplicate entry found in table");
}
} catch (err) {
console.log("Error occurred: " + err);
} finally {
conn.release();
}
}
checkForDuplicates();
2222
2
let value1 = "pk";
let value2 = "bxr";
const mysql = require('mysql');
const connection = mysql.createConnection({
host: 'localhost',
user: 'root',
password: 'root@123',
database: 'abc'
});
connection.connect();
connection.query('SELECT COUNT(*) FROM users WHERE name = ? AND address = ?', [value1, value2], function (error, results, fields) {
if (error) throw error;
let count = results[0]['COUNT(*)'];
if (count == 0) {
connection.query('INSERT INTO users (name, address) VALUES (?, ?)', [value1, value2], function (error, results, fields) {
if (error) throw error;
console.log("Data inserted successfully");
});
} else {
console.log("Duplicate entry found in table");
}
});
333
const mysql = require('mysql');
const connection = mysql.createConnection({
host: 'localhost',
user: 'root',
password: 'root@123',
database: 'abc'
});
connection.connect(function(err) {
if (err) throw err;
console.log("Connected to the database!");
const data = {
name: 'John Doe',
address: 'com'
};
const checkQuery = `SELECT * FROM users WHERE name = '${data.name}' AND address = '${data.address}'`;
connection.query(checkQuery, function (error, results, fields) {
if (error) throw error;
if (results.length === 0) {
const insertQuery = `INSERT INTO users SET ?`;
connection.query(insertQuery, data, function (error, results, fields) {
if (error) throw error;
console.log("Data inserted successfully");
});
} else {
console.log("Data already exists");
}
connection.end(function(err) {
if (err) throw err;
console.log("Connection closed");
});
});
});
0 Comments