一、利用容器部署mysql

1、首先通过docker pull mysql拉取mysql镜像

[root@k8s-master ~]# docker pull mysql
Using default tag: latest
Trying to pull repository docker.io/library/mysql ...
latest: Pulling from docker.io/library/mysql
a4b007099961: Pull complete
e2b610d88fd9: Pull complete
38567843b438: Pull complete
5fc423bf9558: Pull complete
aa8241dfe828: Pull complete
cc662311610e: Pull complete
9832d1192cf2: Pull complete
f2aa1710465f: Pull complete
4a2d5722b8f3: Pull complete
3a246e8d7cac: Pull complete
2f834692d7cc: Pull complete
a37409568022: Pull complete
Digest: sha256:b2ae0f527005d99bacdf3a220958ed171e1eb0676377174f0323e0a10912408a
Status: Downloaded newer image for docker.io/mysql:latest
[root@k8s-master ~]# docker images |grep mysql
docker.io/mysql                                                       latest              562c9bc24a08        3 days ago          521 MB
[root@k8s-master ~]#

2、利用该镜像运行mysql容器， docker run --name mysql -d -p 1234:3306 -e MYSQL_ROOT_PASSWORD=root docker.io/mysql:latest

[root@k8s-master ~]# docker run --name mysql -d -p 1234:3306 -e MYSQL_ROOT_PASSWORD=root docker.io/mysql:latest
9b11e63ec55c451c6ba28a36afd87c0c68462c3cfd83400873f463edb299cd4b
[root@k8s-master ~]# docker ps -l
CONTAINER ID        IMAGE                    COMMAND                  CREATED             STATUS              PORTS                               NAMES
9b11e63ec55c        docker.io/mysql:latest   "docker-entrypoint..."   7 seconds ago       Up 7 seconds        33060/tcp, 0.0.0.0:1234->3306/tcp   mysql
[root@k8s-master ~]#

注：

这里 ‘-e’ 代表传入的环境变量
PORTS为 33060/tcp, 0.0.0.0:1234->3306/tcp，代表容器暴露的mysql服务端口是3306和33060（通常3306是mysql的默认端口，供mysql客户端连接；33060是mysql拓展接口的默认端口），同时将本地的1234端口映射到3306，目的是在本地就可以访问mysql

3、执行docker exec -it CONTAINER ID /bin/bash进入容器，并登录mysql

[root@k8s-master ~]# docker exec -it 9b11e63ec55c /bin/bash
root@9b11e63ec55c:/# mysql -uroot -p
Enter password:
Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 8
Server version: 8.0.28 MySQL Community Server - GPL

Copyright (c) 2000, 2022, Oracle and/or its affiliates.

Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql>

4、通过授权的方式 grant all privileges on . to ‘root’@’%’ 开启mysql的远程访问

mysql> grant all privileges on *.* to 'root'@'%';
Query OK, 0 rows affected (0.00 sec)

mysql> flush privileges;
Query OK, 0 rows affected (0.00 sec)

mysql>

二、利用"database/sql"访问mysql

package main

import (
	"database/sql"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
	"log"
)

func main() {
	db, err := sql.Open("mysql", "root:root@tcp(192.168.101.109:1234)/mysql")
	if err != nil {
		log.Panic(err)
	}
	defer db.Close()
	rows, err := db.Query("select host from user")
	if err != nil {
		log.Panic(err)
	}
	defer rows.Close()
	var host string
	for rows.Next() {
		if err = rows.Scan(&host); err != nil {
			log.Panic(err)
		}
		fmt.Println(host)
	}
}

先看下执行结果

%
localhost
localhost
localhost
localhost

sql.Open(“mysql”, “root:root@tcp(192.168.101.109:1234)/mysql”) 打开了一个数据库，第一个参数就是为了注册mysql驱动，第二个参数格式是"用户名:密码@tcp(mysql服务所在主机ip:mysql服务所在主机端口)/数据库名"

注：
"github.com/go-sql-driver/mysql"这个包执行了init函数

func init() {
	sql.Register("mysql", &MySQLDriver{})
}

调用了database/sql里的Register函数，注册了mysql(drivers[name] = driver)

func Register(name string, driver driver.Driver) {
	driversMu.Lock()
	defer driversMu.Unlock()
	if driver == nil {
		panic("sql: Register driver is nil")
	}
	if _, dup := drivers[name]; dup {
		panic("sql: Register called twice for driver " + name)
	}
	drivers[name] = driver
}