MySQL - INSERT 插入查询

要通过 Node.js 程序将数据插入 MySQL 表，我们需要使用 mysql2 库的 query 函数执行 INSERT 语句，如下所示:-

sql = "INSERT INTO tutorials_tbl VALUES(1, 'Learn PHP', 'John Paul', NOW())";
con.query(sql)

要通过 Java 程序将数据插入 MySQL 表，我们需要使用 JDBC 函数 executeUpdate() 执行 INSERT 语句，如下所示:-

String sql = "INSERT INTO tutorials_tbl VALUES (1, 'Learn PHP', 'John Paul', NOW());";
st.executeUpdate(sql);

要通过 Python 程序将数据插入 MySQL 表，我们需要使用 MySQL Connector/Python 的 execute() 函数执行 INSERT 语句，如下所示:-

sql = "INSERT INTO tutorials_tbl VALUES (1, 'Learn PHP', 'John Paul', '2023-3-28')"
cursorObj.execute(sql)

var mysql = require('mysql2');
var con = mysql.createConnection({
   host: "localhost",
   user: "root",
   password: "Nr5a0204@123"
});
//连接到 MySQL
con.connect(function (err) {
if (err) throw err;
console.log("Connected!");
//创建数据库
sql = "CREATE DATABASE IF NOT EXISTS TUTORIALS"
con.query(sql);
//选择数据库
sql = "USE TUTORIALS"
con.query(sql);
//创建一个表
sql = "CREATE TABLE IF NOT EXISTS tutorials_tbl(tutorial_id INT NOT NULL PRIMARY KEY, tutorial_title VARCHAR(100) NOT NULL, tutorial_author VARCHAR(40) NOT NULL, submission_date DATE)";
con.query(sql);
//将记录插入表中
sql = "INSERT INTO tutorials_tbl(tutorial_id, tutorial_title, tutorial_author, submission_date) VALUES(1, 'Learn PHP', 'John Paul', NOW()), (2, 'Learn MySQL', 'Abdul S', NOW()), (3, 'JAVA Tutorial', 'Sanjay', '2007-05-06'), (4, 'Python Tutorial', 'Sasha Lee', '2016-09-04'), (5, 'Hadoop Tutorial', 'Chris Welsh', NOW())";
 con.query(sql, function (err, result) {
   if (err) throw err;
      console.log(result);
   });
});

输出

生成的输出如下 -

Connected!
-----------------------------------
ResultSetHeader {
  fieldCount: 0,
  affectedRows: 5,
  insertId: 0,
  info: 'Records: 5  Duplicates: 0  Warnings: 3',
  serverStatus: 2,
  warningStatus: 3,
  changedRows: 0
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class InsertQuery {
   public static void main(String[] args) {
      String url = "jdbc:mysql://localhost:3306/TUTORIALS";
      String user = "root";
      String password = "password";
      ResultSet rs;
      try {
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection con = DriverManager.getConnection(url, user, password);
        Statement st = con.createStatement();
        //System.out.println("Database connected successfully...!");
        String sql = "INSERT INTO tutorials_tbl (tutorial_id, tutorial_title, tutorial_author, submission_date) VALUES (1, 'Learn PHP', 'John Paul', NOW());";
        st.executeUpdate(sql);
        System.out.println("Record insered successfully...!");
        System.out.println("Table records: ");
        String sql1 = "SELECT * FROM tutorials_tbl";
        rs = st.executeQuery(sql1);
        while(rs.next()) {
          String tutorial_id = rs.getString("tutorial_id");
          String tutorial_title = rs.getString("tutorial_title");
          String tutorial_author = rs.getString("tutorial_author");
          String submission_date = rs.getString("submission_date");
          System.out.println("Id: " + tutorial_id + ", Title: " + tutorial_title + ", Author: " + tutorial_author + ", Submission_date: " + submission_date);
        }
     }catch(Exception e) {
        e.printStackTrace();
     }
   }
}

输出

获得的输出如下所示 -

Record insered successfully...!
Table records: 
Id: 1, Title: Learn PHP, Author: John Paul, Submission_date:
2023-08-08

import mysql.connector
import datetime
#建立连接
connection = mysql.connector.connect(
    host='localhost',
    user='root',
    password='password',
    database='tut'
)
table_name = 'tutorials_tbl'
new_tutorial_data = [
    (2, 'Learn MySQL', 'Abdul S', '2023-03-28'),
    (3, 'JAVA Tutorial', 'Sanjay', '2007-05-06'),
    (4, 'Python Tutorial', 'Sasha Lee', '2016-09-04'),
    (5, 'Hadoop Tutorial', 'Chris Welsh', '2023-03-28'),
    (6, 'R Tutorial', 'Vaishnav', '2011-11-04')
]
#创建游标对象
cursorObj = connection.cursor()
cursorObj.execute("truncate table tutorials_tbl")
sql = "INSERT INTO tutorials_tbl VALUES (1, 'Learn PHP', 'John Paul', '2023-3-28')"
cursorObj.execute(sql)
insert_query = f'INSERT INTO {table_name} (tutorial_id, tutorial_title, tutorial_author, submission_date) VALUES (%s, %s, %s, %s)'
cursorObj.executemany(insert_query, new_tutorial_data)
connection.commit()
print("Row inserted successfully.")
cursorObj.close()
connection.close()

输出

以下是上述代码的输出 -

Row inserted successfully.