go使用mysql实现增删改查操作

news2025/1/14 10:27:06

1、安装MySQL驱动

go get -u github.com/go-sql-driver/mysql

2、go连接MySQL

import (
	"database/sql"
	"log"

	_ "github.com/go-sql-driver/mysql" // 导入 mysql 驱动
)

type Users struct {
	ID    int
	Name  string
	Email string
}

var db *sql.DB

func init() {
	// 打开或创建一个 SQLite 数据库文件
	var err error
	db, err = sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test?parseTime=true")
	if err != nil {
		log.Fatal(err)
	}
	// 测试连接
	if err = db.Ping(); err != nil {
		log.Fatal(err)
	}
	// 创建用户表
	createTableSQL := `
	CREATE TABLE IF NOT EXISTS users (
		id INT AUTO_INCREMENT PRIMARY KEY,
		name varchar(64) NOT NULL,
		email varchar(64) NOT NULL UNIQUE
	);
	`
	// 执行 SQL 语句
	_, err = db.Exec(createTableSQL)
	if err != nil {
		log.Fatal(err)
	}
}

3、users表增删改查SQL

// CreateUser 创建新用户
func (u *Users) CreateUser() (int64, error) {
	stmt, err := db.Prepare("INSERT INTO users (name, email) VALUES (?, ?)")
	if err != nil {
		return 0, err
	}
	res, err := stmt.Exec(u.Name, u.Email)
	if err != nil {
		return 0, err
	}
	return res.LastInsertId()
}

// GetUserByID 根据 ID 获取用户
func (u *Users) GetUserByID(id int) error {
	row := db.QueryRow("SELECT id, name, email FROM users WHERE id = ?", id)
	return row.Scan(&u.ID, &u.Name, &u.Email)
}

// GetAllUsers 获取所有用户
func GetAllUsers() ([]*Users, error) {
	rows, err := db.Query("SELECT id, name, email FROM users")
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var users []*Users
	for rows.Next() {
		user := &Users{}
		if err := rows.Scan(&user.ID, &user.Name, &user.Email); err != nil {
			return nil, err
		}
		users = append(users, user)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return users, nil
}

// UpdateUser 更新用户信息
func (u *Users) UpdateUser() (int64, error) {
	stmt, err := db.Prepare("UPDATE users SET name = ?, email = ? WHERE id = ?")
	if err != nil {
		return 0, err
	}
	res, err := stmt.Exec(u.Name, u.Email, u.ID)
	if err != nil {
		return 0, err
	}
	return res.RowsAffected()
}

// DeleteUser 删除用户
func (u *Users) DeleteUser() (int64, error) {
	stmt, err := db.Prepare("DELETE FROM users WHERE id = ?")
	if err != nil {
		return 0, err
	}
	res, err := stmt.Exec(u.ID)
	if err != nil {
		return 0, err
	}
	return res.RowsAffected()
}

4、操作增删改查操作

// 创建用户
user := &Users{Name: "buddha", Email: "3539949705@qq.com"}
id, err := user.CreateUser()
if err != nil {
	log.Fatalf("Failed to create user: %v", err)
}
fmt.Printf("Created user with ID: %d\n", id)

// 获取用户
user = &Users{}
if err := user.GetUserByID(int(id)); err != nil {
	log.Fatalf("Failed to get user: %v", err)
}
fmt.Printf("User: ID: %d, Name: %s, Email: %s\n", user.ID, user.Name, user.Email)

// 更新用户
user.Name = "buddha2080"
user.Email = "3539949704@qq.com"
affectedRows, err := user.UpdateUser()
if err != nil {
	log.Fatalf("Failed to update user: %v", err)
}
fmt.Printf("Updated %d rows\n", affectedRows)

// 获取所有用户
users, err := GetAllUsers()
if err != nil {
	log.Fatalf("Failed to get all users: %v", err)
}
for _, u := range users {
	fmt.Printf("User: id: %d, name: %s, email: %s\n", u.ID, u.Name, u.Email)
}

// 删除用户
affectedRows, err = user.DeleteUser()
if err != nil {
	log.Fatalf("Failed to delete user: %v", err)
}
fmt.Printf("Deleted %d rows\n", affectedRows)

整体测试代码如下：

// main.go
package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/go-sql-driver/mysql" // 导入 mysql 驱动
)

type Users struct {
	ID    int
	Name  string
	Email string
}

var db *sql.DB

func init() {
	// 打开或创建一个 SQLite 数据库文件
	var err error
	db, err = sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test?parseTime=true")
	if err != nil {
		log.Fatal(err)
	}
	// 测试连接
	if err = db.Ping(); err != nil {
		log.Fatal(err)
	}
	// 创建用户表
	createTableSQL := `
	CREATE TABLE IF NOT EXISTS users (
		id INT AUTO_INCREMENT PRIMARY KEY,
		name varchar(64) NOT NULL,
		email varchar(64) NOT NULL UNIQUE
	);
	`
	// 执行 SQL 语句
	_, err = db.Exec(createTableSQL)
	if err != nil {
		log.Fatal(err)
	}
}

// CreateUser 创建新用户
func (u *Users) CreateUser() (int64, error) {
	stmt, err := db.Prepare("INSERT INTO users (name, email) VALUES (?, ?)")
	if err != nil {
		return 0, err
	}
	res, err := stmt.Exec(u.Name, u.Email)
	if err != nil {
		return 0, err
	}
	return res.LastInsertId()
}

// GetUserByID 根据 ID 获取用户
func (u *Users) GetUserByID(id int) error {
	row := db.QueryRow("SELECT id, name, email FROM users WHERE id = ?", id)
	return row.Scan(&u.ID, &u.Name, &u.Email)
}

// GetAllUsers 获取所有用户
func GetAllUsers() ([]*Users, error) {
	rows, err := db.Query("SELECT id, name, email FROM users")
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var users []*Users
	for rows.Next() {
		user := &Users{}
		if err := rows.Scan(&user.ID, &user.Name, &user.Email); err != nil {
			return nil, err
		}
		users = append(users, user)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return users, nil
}

// UpdateUser 更新用户信息
func (u *Users) UpdateUser() (int64, error) {
	stmt, err := db.Prepare("UPDATE users SET name = ?, email = ? WHERE id = ?")
	if err != nil {
		return 0, err
	}
	res, err := stmt.Exec(u.Name, u.Email, u.ID)
	if err != nil {
		return 0, err
	}
	return res.RowsAffected()
}

// DeleteUser 删除用户
func (u *Users) DeleteUser() (int64, error) {
	stmt, err := db.Prepare("DELETE FROM users WHERE id = ?")
	if err != nil {
		return 0, err
	}
	res, err := stmt.Exec(u.ID)
	if err != nil {
		return 0, err
	}
	return res.RowsAffected()
}

func main() {
	fmt.Println("main函数开始...")

	// 创建用户
	user := &Users{Name: "buddha", Email: "3539949705@qq.com"}
	id, err := user.CreateUser()
	if err != nil {
		log.Fatalf("Failed to create user: %v", err)
	}
	fmt.Printf("Created user with ID: %d\n", id)

	// 获取用户
	user = &Users{}
	if err := user.GetUserByID(int(id)); err != nil {
		log.Fatalf("Failed to get user: %v", err)
	}
	fmt.Printf("User: ID: %d, Name: %s, Email: %s\n", user.ID, user.Name, user.Email)

	// 更新用户
	user.Name = "buddha2080"
	user.Email = "3539949704@qq.com"
	affectedRows, err := user.UpdateUser()
	if err != nil {
		log.Fatalf("Failed to update user: %v", err)
	}
	fmt.Printf("Updated %d rows\n", affectedRows)

	// 获取所有用户
	users, err := GetAllUsers()
	if err != nil {
		log.Fatalf("Failed to get all users: %v", err)
	}
	for _, u := range users {
		fmt.Printf("User: id: %d, name: %s, email: %s\n", u.ID, u.Name, u.Email)
	}

	// 删除用户
	affectedRows, err = user.DeleteUser()
	if err != nil {
		log.Fatalf("Failed to delete user: %v", err)
	}
	fmt.Printf("Deleted %d rows\n", affectedRows)

	fmt.Println("main函数结束...")
}

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2251504.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

vulnhub靶场【哈利波特】三部曲之Fawkes

vulnhub靶场【哈利波特】三部曲之Fawkes

前言 这次的靶机与前面不同，这里涉及到缓冲区溢出等 这个靶机也让我知道薄弱点了，缓冲溢出这方面之前接触少，所以刚拿到这个靶机打开后，人蒙了，在网上查阅好多资料，也只是浅学一下，这里主要也是…
阅读更多...
mac下安装Ollama + Open WebUI + Llama3.1

mac下安装Ollama + Open WebUI + Llama3.1

本文介绍mac下安装Ollama Open WebUI Llama3.1 8b具体步骤。 目录 推荐配置Ollama Open WebUI Llama3.1简介安装Ollama安装Open WebUI 推荐配置 m1以上芯片，16g内存，20g以上硬盘空间 Ollama Open WebUI Llama3.1简介 Ollama: 下载，管理…
阅读更多...
Android 图形系统之四：Choreographer

Android 图形系统之四：Choreographer

Choreographer 是 Android 系统中负责帧同步的核心组件，它协调输入事件、动画和绘制任务，以确保界面以固定频率（通常是每 16ms，一帧）流畅渲染。通过管理 VSYNC 信号和调度任务，Choreographer 是实现流畅 UI…
阅读更多...
如何构建一个可扩展、全球可访问的 GenAI 架构？

如何构建一个可扩展、全球可访问的 GenAI 架构？

你有没有尝试过使用人工智能生成图像？ 如果你尝试过，你就会知道，一张好的图像的关键在于一个详细具体的提示。 我不擅长这种详细的视觉提示，所以我依赖大型语言模型来生成详细的提示，然后使用这些提示来生成出色的图像…
阅读更多...
ceph手动部署

ceph手动部署

ceph手动部署 一、 节点规划 主机名IP地址角色ceph01.example.com172.18.0.10/24mon、mgr、osd、mds、rgwceph02.example.com172.18.0.20/24mon、mgr、osd、mds、rgwceph03.example.com172.18.0.30/24mon、mgr、osd、mds、rgw 操作系统版本： Rocky Linux release …
阅读更多...
【iOS】多线程基础

【iOS】多线程基础

【iOS】多线程基础 文章目录 【iOS】多线程基础前言进程与线程进程进程的状态进程的一个控制结构进程的上下文切换 线程为什么要用线程什么是线程线程和进程的关系线程的上下文切换 线程和进程的优缺点 小结 前言 笔者由于对于GCD不是很了解，导致了项目中网络请求哪…
阅读更多...
ArraList和LinkedList区别

ArraList和LinkedList区别

文章目录 一、结构不同二、访问速度三、插入和删除操作的不同1、决定效率有两个因素：数据量和位置。2、普遍说法是“LinkedList添加删除快”，这里是有前提条件的 四、内存占用情况五、使用场景六、总结 一、结构不同 LinkedList：它基于双向链…
阅读更多...
芯片测试-RF中的S参数，return loss, VSWR，反射系数，插入损耗，隔离度等

芯片测试-RF中的S参数，return loss, VSWR，反射系数，插入损耗，隔离度等

RF中的S参数，return loss, VSWR，反射系数，插入损耗，隔离度 💢S参数💢💢S11与return loss，VSWR，反射系数💢💢S21，插入损耗和增益&#…
阅读更多...
arkTS：持久化储存UI状态的基本用法（PersistentStorage）

arkTS：持久化储存UI状态的基本用法（PersistentStorage）

arkUI：持久化储存UI状态的基本用法（PersistentStorage） 1 主要内容说明2 例子2.1 持久化储存UI状态的基本用法（PersistentStorage）2.1.1 源码1的相关说明2.1.1.1 数据存储2.1.1.2 数据读取2.1.1.3 动态更新2.1.1.4 显示…
阅读更多...
《Django 5 By Example》阅读笔记：p455-p492

《Django 5 By Example》阅读笔记：p455-p492

《Django 5 By Example》学习第 16 天，p455-p492 总结，总计 38 页。 一、技术总结 1.myshop (1)打折功能 使用折扣码实现，但是折扣码是手动生成的，感觉实际业务中应该不是这样的。 (2)推荐功能 使用 Redis 做缓存&#xff0…
阅读更多...
深入浅出：开发者如何快速上手Web3生态系统

深入浅出：开发者如何快速上手Web3生态系统

Web3作为互联网的未来发展方向，正在逐步改变传统互联网架构，推动去中心化技术的发展。对于开发者而言，Web3代表着一个充满机遇与挑战的新领域，学习和掌握Web3的基本技术和工具，将为未来的项目开发提供强大的支持。那么…
阅读更多...
otter 高可用策略

otter 高可用策略

关于otter高可用在设计之初，提供了这样几个基本的需求： 1.网络不可靠，异地机房尤为明显. 2.manager/node的jvm不可靠，需要考虑异常crash情况 3.node的jvm不可靠，需要考虑异常crash的情况 4.数据库不可靠，需…
阅读更多...
C底层 函数栈帧

C底层 函数栈帧

文章目录 一，什么是寄存器 二，栈和帧 前言 我们在学习c语言程序的时候，是不是有很多的疑问，如 1，为什么形参不可以改变实参 2，为什么我们编写程序的时候会出现烫烫烫......这个乱码 3，那些局…
阅读更多...
力扣1382：将二叉搜索树便平衡

力扣1382：将二叉搜索树便平衡

给你一棵二叉搜索树，请你返回一棵 平衡后 的二叉搜索树，新生成的树应该与原来的树有着相同的节点值。如果有多种构造方法，请你返回任意一种。 如果一棵二叉搜索树中，每个节点的两棵子树高度差不超过 1 ，我们就称这棵二…
阅读更多...
亚马逊自研大语言模型 Olympus 即将亮相，或将在 LLM 竞赛中掀起新波澜

亚马逊自研大语言模型 Olympus 即将亮相，或将在 LLM 竞赛中掀起新波澜

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗？订阅我们的简报，深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同，从行业内部的深度分析和实用指南中受益。不要错过这个机会，成为AI领…
阅读更多...
指针与引用错题汇总

指针与引用错题汇总

int *p[3]; // 定义一个包含 3 个指向 int 的指针的数组int a 10, b 20, c 30; p[0] &a; // p[0] 指向 a p[1] &b; // p[1] 指向 b p[2] &c; // p[2] 指向 c // 访问指针所指向的值 printf("%d %d %d\n", *p[0], *p[1], *p[2]); // 输出: 10 20 30…
阅读更多...
vscode ctrl+/注释不了css

vscode ctrl+/注释不了css

方式一.全部禁用插件排查问题. 方式二.打开首选项的json文件,注释掉setting.json,排查是哪一行配置有问题. 我的最终问题:需要将 "*.vue": "vue",改成"*.vue": "html", "files.associations": { // "*.vue": &qu…
阅读更多...
医疗知识图谱的问答系统详解

医疗知识图谱的问答系统详解

一、项目介绍 该项目的数据来自垂直类医疗网站寻医问药，使用爬虫脚本data_spider.py，以结构化数据为主，构建了以疾病为中心的医疗知识图谱，实体规模4.4万，实体关系规模30万。schema的设计根据所采集的结构化数据生成&…
阅读更多...
上传镜像docker hub登不上和docker desktop的etx4.vhdx占用空间很大等解决办法

上传镜像docker hub登不上和docker desktop的etx4.vhdx占用空间很大等解决办法

平时使用docker一般都在Linux服务器上，但这次需要将镜像上传到docker hub上，但是服务器上一直无法登录本人的账号，（这里的问题应该docker 网络配置中没有开代理的问题，因服务器上有其他用户使用，不可能直接…
阅读更多...
大型复杂项目管理怎么结合传统与敏捷

大型复杂项目管理怎么结合传统与敏捷

大型复杂项目管理需要综合运用传统的瀑布模型与敏捷方法，两者各具优势，可以在不同的项目阶段和需求下发挥最大效能。首先，在项目的初期阶段，传统方法的详细规划和需求分析能够帮助确保项目方向正确、资源充足；敏捷方法…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023