GVKun编程网logo

Node.js 实现 MySQL 数据库增删改查（nodejs操作mysql数据库）

1

针对Node.js实现MySQL数据库增删改查和nodejs操作mysql数据库这两个问题，本篇文章进行了详细的解答，同时本文还将给你拓展12-9javaweb数据库增删改查、6django-数据库增

针对Node.js 实现 MySQL 数据库增删改查和nodejs操作mysql数据库这两个问题，本篇文章进行了详细的解答，同时本文还将给你拓展12-9java web 数据库增删改查、6django-数据库增删改查、centos7 设置 mysql 自启动的配置文件中 [Service] User=mysql Group=mysql，user 和 group 这边的 mysql 是指的什么？centos 的登录用户名？、Django ORM 数据库增删改查等相关知识，希望可以帮助到你。

本文目录一览：

Node.js 实现 MySQL 数据库增删改查（nodejs操作mysql数据库）

Node.js 实现 MySQL 数据库增删改查（nodejs操作mysql数据库）

安装mysql

$ npm isntall mysql

连接数据库

需要根据实际配置修改数据库用户名、及密码及数据库名

let mysql = require(''mysql'');

let connection = mysql.createConnection({
  host: ''localhost'',
  user: ''***'', // 用户名
  password: ''***'', // 密码
  port: ''3306'',
  database: ''node_mysql_test'' // 数据库名称
});

connection.connect((err, result) => {
  if (err) {
    console.log(err);
    console.log("连接失败");
    return;
  }
  console.log(result);
  console.log("连接成功");
});

connection.end(); // 结束连接

在 MySQL 数据库中创建初始数据

终端输入：

mysql -u 【数据库名称】 -p

mysql> create database node_mysql_test default character set utf8 default collate utf8_general_ci;

mysql> use node_mysql_test;

mysql> source 『将users.sql文件直接拖拽至终端，自动补全其文件目录』

将users.sql文件如下：

SET NAMES utf8;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
--  Table structure for `users`
-- ----------------------------
DROP TABLE IF EXISTS `users`;

CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` char(20) NOT NULL DEFAULT '''' COMMENT ''姓名'',
  `email` varchar(255) NOT NULL DEFAULT '''',
  `age` int(11) NOT NULL DEFAULT ''0'' COMMENT ''年龄'',
  `city` char(10) NOT NULL DEFAULT '''' COMMENT ''城市'',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;

-- ----------------------------
--  Records of `users`
-- ----------------------------
BEGIN;
INSERT INTO `users` VALUES (''1'', ''张三'', ''zhangsan@qq.com'', ''18'', ''上海''), (''2'', ''李四'', ''1234@163.com'', ''23'', ''重庆''), (''3'', ''王五'', ''abc@sina.cn'', ''33'', ''青岛''), (''4'', ''马六'', ''666@qq.com'', ''19'', ''南京'');
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;

查询数据

let mysql = require(''mysql'');

let connection = mysql.createConnection({
  host: ''localhost'',
  user: ''***'',
  password: ''***'',
  port: ''3306'',
  database: ''node_mysql_test''
});

connection.connect((err, result) => {
  if (err) {
    console.log(err);
    console.log("连接失败");
    return;
  }
  console.log(result);
  console.log("连接成功");
});

/**
 * -------------------
 * 查询数据
 * -------------------
 */

let selectSql = ''SELECT * FROM users'';

connection.query(selectSql, (err, result) => {
  if (err) {
    console.log(''[SELECT 失败] - '', err.message);
    return;
  }

  console.log(''--------------SELECT------------'');
  console.log(''查询成功:'',result);
  console.log(''--------------------------\n\n'');
});


connection.end();

增加数据


let mysql = require(''mysql'');

let connection = mysql.createConnection({
  host: ''localhost'',
  user: ''***'',
  password: ''***'',
  port: ''3306'',
  database: ''node_mysql_test''
});

connection.connect((err, result) => {
  if (err) {
    console.log(err);
    console.log("连接失败");
    return;
  }
  console.log(result);
  console.log("连接成功");
});

/**
 * -------------------
 * 增加数据
 * -------------------
 */

let addSql = ''INSERT INTO users(Id,name,email,age,city) VALUES(0,?,?,?,?)'';
let addSqlParams = [''赵七'', ''777@qq.com'', ''22'', ''大连''];

connection.query(addSql, addSqlParams, (err, result) => {
  if (err) {
    console.log(''[增加失败] - '', err.message);
    return;
  }

  console.log(''--------------INSERT-------------'');
  console.log(''增加成功 ID:'',result.insertId);
  console.log(''增加成功:'', result);
  console.log(''--------------------------------\n\n'');
});

connection.end();

更新数据

let mysql = require(''mysql'');

let connection = mysql.createConnection({
  host: ''localhost'',
  user: ''***'',
  password: ''***'',
  port: ''3306'',
  database: ''node_mysql_test''
});

connection.connect((err, result) => {
  if (err) {
    console.log(err);
    console.log("连接失败");
    return;
  }
  console.log(result);
  console.log("连接成功");
});

/**
 * -------------------
 * 更新数据
 * -------------------
 */

let modSql = ''UPDATE users SET name = ?,email = ? WHERE Id = ?'';
let modSqlParams = [''Tom'', ''tom@qq.com'', 7];

connection.query(modSql, modSqlParams,  (err, result) => {
  if (err) {
    console.log(''[更新失败] - '', err.message);
    return;
  }
  console.log(''----------UPDATE---------------'');
  console.log(''更新成功'', result.affectedRows);
  console.log(''-------------------------------\n\n'');
});


connection.end();

删除数据

let mysql = require(''mysql'');

let connection = mysql.createConnection({
  host: ''localhost'',
  user: ''***'',
  password: ''***'',
  port: ''3306'',
  database: ''node_mysql_test''
});

connection.connect((err, result) => {
  if (err) {
    console.log(err);
    console.log("连接失败");
    return;
  }
  console.log(result);
  console.log("连接成功");
});

/**
 * -------------------
 * 删除数据
 * -------------------
 */

let delSql = ''DELETE FROM users where id=4'';

connection.query(delSql, (err, result) => {
  if (err) {
    console.log(''[删除失败] - '', err.message);
    return;
  }

  console.log(''--------DELETE---------------'');
  console.log(''删除成功'', result.affectedRows);
  console.log(''------------------------\n\n'');
});

connection.end();

12-9java web 数据库增删改查

12-9java web 数据库增删改查

首先大体的java结构框架是这样

很重要的一点是建立数据库的连接

数据库是一切操作的前提 不管是增加 删除 修改 查询 都需要调用数据库连接程序

 

 再就是java的类的编写  写完类后需要对其进行增删改查方法的 编写

 

这是dao层的增删改查的操作

这是类的编写

severlet 是jsp 与数据库连接的接口

下面是建立jsp 网页界面的大致结构

连接数据库要有jar包

数据库中 要有 id 等属性 。

6django-数据库增删改查

6django-数据库增删改查

 

 

 

 

 

 

 

 

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<h2><a href="/show/">部门管理</a></h2>
</body>
</html>
****************************************************************
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>部门表</title>
    <style>

    </style>

</head>
<body>

<h2>部门表</h2>
<table border="1" width="600">
    <tr>
        <td>部门编号</td>
        <td>部门名称</td>
        <td>部门简介</td>
        <td>操作</td>
    </tr>
    {% for ii in deptlist %}
    <tr>
        <td>{{ ii.deptno }}</td>
        <td>{{ ii.dname }}</td>
        <td>{{ ii.djianjie }}</td>
        <td><a href="/xiugai/{{ ii.deptno }}">修改</a>/<a href="/shanchu/{{ ii.deptno }}">删除</a></td>
    </tr>
        {% empty %}
        <tr>
        <td colspan="4">内容为空</td>

    </tr>

    {% endfor %}
</table>
<br>
<form method="get" action="/app/">
    {% csrf_token %}
    <button type="submit">添加数据</button>
</form>

</body>
</html>
***********************************************************************************
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<h2>添加部门</h2>
<form method="post" action="/app/">
    {% csrf_token %}

    部门名称：<input type="text" name="names"><br>
    部门简介：<input type="text" name="jianjie"><br>
    <button type="submit">提交</button>
</form>
</body>
</html>
***************************************************************************************
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<form method="post" action="/xiugai/{{ xiu.deptno }}">
    {% csrf_token %}

    部门名称：<input type="text" name="names" value="{{ xiu.dname }}"><br>
    部门简介：<input type="text" name="jianjie" value="{{ xiu.djianjie }}"><br>
    <button type="submit">提交</button>
</form>
</body>
</html>
from django.shortcuts import render
from app.models import Bumen
from django.http import HttpResponseRedirect

# Create your views here.
def index(request):
    return render(request,''index.html'')

def show(request):
    ref=Bumen.objects.all()
    content={}
    content[''deptlist'']=ref
    return render(request,''bumen.html'',content)

def app(request):
    if request.POST:
        name = request.POST.get(''names'')
        jianjie = request.POST.get(''jianjie'')
        Bumen.objects.create(dname=name,djianjie=jianjie)
        print(''添加成功'')
        return HttpResponseRedirect(''/show/'')
    else:
        return render(request,''app.html'')

def shanchu(request,deptno):
    #Bumen.objects.filter(deptno=deptno).delete()
    Bumen.objects.get(deptno=deptno).delete()
    return HttpResponseRedirect(''/show/'')


def xiugai(request,deptno):
    if request.POST:
        name=request.POST.get(''names'')
        jianjie=request.POST.get(''jianjie'')
        Bumen.objects.filter(deptno=deptno).update(dname=name,djianjie=jianjie)
        return HttpResponseRedirect(''/show/'')
    else:
        print(deptno)
        bumen=Bumen.objects.get(deptno=deptno)
        print(bumen)
        content={}
        content[''xiu'']=bumen
        return render(request,''xiugai.html'',content)





*******************************************
from django.db import models

# Create your models here.
class Bumen(models.Model):
    deptno=models.AutoField(primary_key=True)
    dname=models.CharField(max_length=30)
    djianjie = models.CharField(max_length=50)
***********************************************
from app.views import show,index,app,shanchu,xiugai

urlpatterns = [
    path(''admin/'', admin.site.urls),
path(''index/'', index),
path(''show/'', show),
path(''app/'', app),
path(''shanchu/<str:deptno>'', shanchu),
path(''xiugai/<str:deptno>'', xiugai),

 

centos7 设置 mysql 自启动的配置文件中 [Service] User=mysql Group=mysql，user 和 group 这边的 mysql 是指的什么？centos 的登录用户名？

centos7 设置 mysql 自启动的配置文件中 [Service] User=mysql Group=mysql，user 和 group 这边的 mysql 是指的什么？centos 的登录用户名？

centos7 设置 mysql 自启动的配置文件中

[Unit]
Description=MySQL Server
Documentation=man:mysqld(8)
Documentation=http://dev.mysql.com/doc/refman/en/using-systemd.html
After=network.target
After=syslog.target

[Install]
WantedBy=multi-user.target

[Service]
User=mysql
Group=mysql
ExecStart=/usr/local/mysql/bin/mysqld --defaults-file=/etc/my.cnf
LimitNOFILE = 5000
#Restart=on-failure
#RestartPreventExitStatus=1
#PrivateTmp=false

这里的

[Service]

User=mysql

Group=mysql，

user 和 group 这边的 mysql 是指的什么？centos 的登录用户名？还是其他呢？

Django ORM 数据库增删改查

Django ORM 数据库增删改查

Django ORM 数据库增删改查

增

# 创建、增加数据(推荐)
models.UserInfo.objects.create(username=''root'',password=''123'')
# 创建、增加数据
dic = {''username'':''eric'',''password'':''666''}
models.UserInfo.objects.create(**dic)
# 创建、增加数据
obj = models.UserInfo(username=''xsk'',password=''123'')
obj.save()

删 

# 删除指定字段的行
models.UserInfo.objects.filter(id=4).delete()
# 删除指定多个字段的行
models.UserInfo.objects.filter(username=''root'',password="123").delete()

改

# 修改指定字段内的所有值变为888
models.UserInfo.objects.all().update(password="888")
# 修改指定id的行修改字段内的值
models.UserInfo.objects.filter(id="3").update(password="777")

查

# 获取表内所有数据  all()
# result返回的是QuerySet类型 => Django类 => []
# 全部都是UserInfo的对象[obj(id,username,password),obj,obj]
result = models.UserInfo.objects.all()
for row in result:
    print(row.id,row.username,row.password)
# 获取username字段中带有root的一行对象值 filter()
result = models.UserInfo.objects.filter(username=''root'')
# 获取username字段中带有root与password字段中带有123的一行对象值 filter()
result = models.UserInfo.objects.filter(username=''root'',password="123")
for row in result:
    print(row.id,row.username,row.password)
# 只获取一条数据
obj = models.UserInfo.objects.first(id=nid).first()

# 查看翻译成的sql语句
models.UserInfo.objects.all().query

 

 

 

其他

# .firest() 获取对象。没有则输出None，有则输出UserInfo object  （常用）
obj = models.UserInfo.objects.filter(username=u,password=p).first()
# .count() 获取个数，没有则输出0。
count = models.UserInfo.objects.filter(username=u,password=p).count()

 

关于Node.js 实现 MySQL 数据库增删改查和nodejs操作mysql数据库的介绍已经告一段落，感谢您的耐心阅读，如果想了解更多关于12-9java web 数据库增删改查、6django-数据库增删改查、centos7 设置 mysql 自启动的配置文件中 [Service] User=mysql Group=mysql，user 和 group 这边的 mysql 是指的什么？centos 的登录用户名？、Django ORM 数据库增删改查的相关信息，请在本站寻找。

本文标签：

上一篇mysql 5.7 迁移数据方案（mysql的数据迁移）

下一篇mysql 案例 ~ mysql安全渗透测试（mysql渗透教程）

相关文章