mysql分批插入数据 // 插入数据的方法 function insetData($Data, $hid, $cateId, $mysqli) { // 创建预处理语句 $stmt = $mysqli->prepare( "INSERT INTO love_learn_class (name, getnoun, noun, price, queryplat, docking, content, addtime, fenlei) VALUES (?, ?, ?, ?, ?, ?, ?, NOW(), ?)" ); // 循环插入数据 foreach ($Data as $value) { // 绑定参数 $stmt->bind_param('sssssssi', $value['name'], $value['cid'], $value['cid'], $value['realPrice'], $hid, $hid, $value['content'], $cateId); // 执行插入操作 $stmt->execute(); } // 在所有插入操作完成后关闭预处理语句 $stmt->close(); } $classTotal = count($classData); // 数据条数 $singleCount = 100; // 每次插入数据的条数 // 数据小于最大单次插入数，直接插入，并跳出循环 if ($classTotal <= $singleCount) { insetData($classData, $hid, $cateId, $mysqli); } else { // 需要循环的次数 $loopCount = ceil($classTotal / $singleCount); // 当前的数据条数 $currentCount = 0; // 循环插入数据 while ($loopCount > 0) { $istClass = array_slice($classData, $currentCount, $singleCount); insetData($istClass, $hid, $cateId, $mysqli); $currentCount += $singleCount; $loopCount--; } }

常用sql语句 查询表中数据-- 通过 * 把 users 中所有的数据查询出来 SELECT * FROM users -- 从 users 表中把 username 和 password 对应的数据查询出来 select username, password from users向表中添加数据-- 向 users 表中插入新数据 INSERT INTO users (username, password) VALUES ('xh', '654321')更新表中数据-- 将 id 为 8 的用户，密码更新成 888888 UPDATE users SET password='888888' WHERE id=8 -- 把 id 为 2 的用户，密码更新为 admin ，状态更新为 1 UPDATE users SET password='admin', status=1 WHERE id=2删除表中数据-- 删除 id 为 9 的用户数据 DELETE FROM users WHERE id=9统计表中数据-- 使用 count(*) 来统计 users 表中，状态为 0 的用户总数量 SELECT count(*) FROM users WHERE status=0使用 AS 关键字给列取别名-- 使用 AS 关键字给列取别名 SELECT count(*) AS total FROM users WHERE status=0

node环境操作数据库 安装 mysql 模块npm i mysql1.导入 mysql 模块// 1.导入 mysql 模块 const mysql = require('mysql')2.建立 mysql 数据库的连接关系// 2.建立 mysql 数据库的连接关系 const db = mysql.createPool({ host: '127.0.0.1', // 数据库地址 port: 3306, // 数据库端口号 user: 'root', // 数据库用户名 password: '123456', // 数据库密码 database: 'my_db_01' // 数据库名称 })3.测试 mysql 模块能否正常工作db.query('select 1', (err, results) => { // mysql 模块工作期间报错了 if(err) return console.log(err.message) // 能够正常执行 MySQL 语句 console.log(results) })查询表中数据// 查询 users 表中的所有数据 const sqlStr = 'select * from users' db.query(sqlStr, (err, results) => { // 查询数据失败 if(err) return console.log(err.message) // 查询数据成功 console.log(results) })向表中添加数据// 向 users 表中，新增一条数据，其中 username 值为 Spider-Man ，password 值为 pcc123 const user = { username: 'Spider-Woman', password: 'pcc123456' } // 定义待执行 SQL 语句 const sqlStr = 'insert into users (username, password) values (?, ?)' // 执行 SQL 语句 db.query(sqlStr, [user.username, user.password], (err, results) => { // 执行 sql 语句失败了 if(err) return console.log(err.message) // 执行成功 if(results.affectedRows === 1) { console.log('添加成功！') } })添加数据的便捷方式const user = { username: 'Spider-Woman2', password: 'pcc123456' } // 定义待执行的 SQL 语句 const sqlStr = 'insert into users set ?' // 执行 sql 语句 db.query(sqlStr, user, (err, results) => { // 执行失败 if(err) return console.log(err.message) // 执行成功 if(results.affectedRows === 1) { console.log('添加成功！') } })更新表中数据// 更新用户信息 const user = { id: 8, username: 'aaa', password: '000' } // 定义 sql 语句 const sqlStr = 'update users set username=?, password=? where id=?' // 执行 sql 语句 db.query(sqlStr, [ user.username, user.password, user.id ], (err, results) => { // 执行 sql 语句失败 if(err) return console.log(err.message) // 执行成功 if(results.affectedRows === 1) { console.log('更改成功！') } })更新表中数据的便捷方式const user = { id: 8, username: 'aaa1', password: '0001' } // 定义 SQL 语句 const sqlStr = 'update users set ? where id=?' // 执行 SQL 语句 db.query(sqlStr, [user, user.id], (err, results) => { // 执行失败 if(err) return console.log(err.message) // 执行成功 if(results.affectedRows === 1) { console.log('更新成功！') } })删除数据// 定义 SQL 语句 const sqlStr = 'delete from users where id=?' // 执行 SQL 语句 db.query(sqlStr, 8, (err, results) => { if(err) return console.log(err.message) if(results.affectedRows === 1) { console.log('删除数据成功！') } })标记删除（避免真实的删除数据）// 标记删除（避免真实的删除数据） const sqlStr ='update users set status=? where id=?' // 执行 SQL 语句 db.query(sqlStr, [1, 11], (err, results) => { // 执行失败 if(err) return console.log(err.message) // 执行成功 if(results.affectedRows === 1) { console.log('删除成功！') } })