实现golang连接MySQL数据库导入执行一个sql文件

package tools

import (
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    "github.com/jinzhu/gorm"
    "io/ioutil"
    "log"
    "os"
    "strings"
    "time"
)

type ImportSqlTool struct {
    SqlPath                                    string
    Username, Password, Server, Port, Database string
}

func (this *ImportSqlTool) ImportSql() error {
    _, err := os.Stat(this.SqlPath)
    if os.IsNotExist(err) {
        log.Println("数据库SQL文件不存在:", err)
        return err
    }

    dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local", this.Username, this.Password, this.Server, this.Port, this.Database)
    db, err := gorm.Open("mysql", dsn)
    if err != nil {
        log.Println("数据库连接失败:", err)
        //panic("数据库连接失败!")
        return err
    }
    db.SingularTable(true)
    db.LogMode(true)
    db.DB().SetMaxIdleConns(10)
    db.DB().SetMaxOpenConns(100)
    db.DB().SetConnMaxLifetime(59 * time.Second)

    sqls, _ := ioutil.ReadFile(this.SqlPath)
    sqlArr := strings.Split(string(sqls), ";")
    for _, sql := range sqlArr {
        sql = strings.TrimSpace(sql)
        if sql == "" {
            continue
        }
        err := db.Exec(sql).Error
        if err != nil {
            log.Println("数据库导入失败:" + err.Error())
            return err
        } else {
            log.Println(sql, "\t success!")
        }
    }
    return nil
}

背景

公司有一个老项目，是给政府部门开发的项目，不清楚当时合同是怎么谈的（那时候我还没有入职），这个管理系统是部署在公司服务器上的。现在他们想把这个系统转移到自己的服务器上，公司管理层面已经同意，剩下就是具体实施了。

对方按要求安装了centos系统，在网络安全方面使用了防火墙、堡垒机这一类的东西，之后就是我的工作了。安装mysql数据库，tomcat服务器，nginx,redis等软件。

适用场景一：将服务器上某个MySQL数据库的表批量导入到本地数据库，而后进行测试。

654、把数据库备份文件导入到本机mysql数据库

教学视频地址：

https://www.ixigua.com/7028722184373666317?id=7095579570912363016&logTag=76d52ffaacc346476487

前言：

日常学习和工作中，经常会遇到导数据的需求。比如数据迁移、数据恢复、新建从库等，这些操作可能都会涉及大量数据的导入。有时候导入进度慢，电脑风扇狂转真的很让人崩溃，其实有些小技巧是可以让导入更快速的，本篇文章笔者会谈一谈如何快速的导入数据。

今天部署供方发过来的mysql数据库升级文件，发现有几十个.sql文件，要导入到数据库中。按照常规方式肯定是用 source ../../..../xx.sql 一个一个的导入了。

结合网上的例子，决定先将所有的.sql文件，放在一个文件里面，然后通过source ../../..../xx.sql一次性导入，方便快捷。这里不是指将.sql文件中的内容一个一个地复制到all.sql中，而是将.sql的路径放置在all.sql，如图，具体原理不叙述了。

当我们需要将数据导入到MySQL数据库中时，有多种不同的方式可供选择，这里介绍MySQL常用的4种导入数据的方法。

1、INSERT INTO

是一种用于将新行插入表中的 SQL 命令。它是 MySQL 最基本、最常用的语句之一，也是许多应用程序的核心功能之一。

NSERT INTO 的语法

一般情况下，SQL文件数据量不大，我比较喜欢登录到MySQL中，然后使用source命令执行，假如SQL文件比较大，在执行的过程中万一出现网络波动，远程连接MySQL断开了，那就很尴尬了，所以最好是后台执行，使用nohup xxx &

这个xxx可以直接使用命令行，或者写一个shell脚本，我习惯把命令行写入一个简单的bash shell脚本文件里去执行。