批量执行sql程序

doc/bulkCreateTable/.idea/.gitignore

@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
+# Editor-based HTTP Client requests
+/httpRequests/

doc/bulkCreateTable/.idea/bulkCreateTable.iml

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
+  <component name="GoLibraries">
+    <option name="urls">
+      <list>
+        <option value="file://$MODULE_DIR$/../common" />
+        <option value="file://$MODULE_DIR$/../mysql" />
+      </list>
+    </option>
+  </component>
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

doc/bulkCreateTable/.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/bulkCreateTable.iml" filepath="$PROJECT_DIR$/.idea/bulkCreateTable.iml" />
+    </modules>
+  </component>
+</project>

doc/bulkCreateTable/.idea/webResources.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="WebResourcesPaths">
+    <contentEntries>
+      <entry url="file://$PROJECT_DIR$">
+        <entryData>
+          <resourceRoots>
+            <path value="file://$PROJECT_DIR$" />
+          </resourceRoots>
+        </entryData>
+      </entry>
+    </contentEntries>
+  </component>
+</project>

doc/bulkCreateTable/sql/alter.txt

@@ -0,0 +1,3 @@
+ALTER TABLE TMPTABLENAME ADD COLUMN account_id VARCHAR(50);
+ALTER TABLE TMPTABLENAME ADD COLUMN data_desc int(10) COMMENT "数据规格1-高级字段包 2-标准字段包";
+ALTER TABLE TMPTABLENAME ADD INDEX  account_id_desc(`account_id`,`data_desc`,`info_id`);

doc/bulkCreateTable/sql/sql.txt

@@ -0,0 +1 @@
+  "createSql": "CREATE TABLE TMPTABLENAME (\nperson_id VARCHAR(50) ,\ninfo_id VARCHAR(50),\nent_id   VARCHAR(50),\nINDEX (person_id,info_id),\nINDEX (ent_id,info_id)\n)"

doc/bulkCreateTable/src/a/init.go

@@ -0,0 +1,26 @@
+package a
+
+import (
+	qu "qfw/util"
+	"qfw/util/mysql"
+)
+
+var (
+	Sysconfig        map[string]interface{}
+	JyMysql          *mysql.Mysql
+
+)
+
+func init() {
+	qu.ReadConfig(&Sysconfig)
+	// 连数据库
+	jyMysql := qu.ObjToMap(Sysconfig["mysql"])
+	JyMysql = &mysql.Mysql{
+		Address:  (*jyMysql)["address"].(string),
+		UserName: (*jyMysql)["username"].(string),
+		PassWord: (*jyMysql)["password"].(string),
+		DBName:   (*jyMysql)["dbName"].(string),
+	}
+	JyMysql.Init()
+}
+

doc/bulkCreateTable/src/config.json

@@ -0,0 +1,14 @@
+{
+  "mysql": {
+    "username": "root",
+    "password": "Topnet123",
+    "address": "192.168.3.11:3366",
+    "dbName": "jianyu"
+  },
+  "table_prefix": "qc",
+  "start": 0,
+  "end": 100,
+  "tmpName": "TMPTABLENAME",
+  "createSql": "ALTER TABLE TMPTABLENAME ADD INDEX  account_id_desc(`account_id`,`data_desc`,`info_id`);"
+
+}

doc/bulkCreateTable/src/main.go

@@ -0,0 +1,36 @@
+package main
+
+import (
+	"a"
+	"fmt"
+	"log"
+	"qfw/util"
+	"strings"
+)
+
+func main() {
+	// 1. 次数
+	log.Println(a.Sysconfig)
+	start := util.IntAll(a.Sysconfig["start"])
+	end := util.IntAll(a.Sysconfig["end"])
+	prefix := a.Sysconfig["table_prefix"].(string)
+	tmpName := a.Sysconfig["tmpName"].(string)
+	createTableStr := a.Sysconfig["createSql"].(string)
+	// for 循环执行语句
+	if start<0{
+		start=0
+	}
+	for i := start; i < end; i++ {
+		tableName := prefix + fmt.Sprintf("%03d", i)
+		log.Println(tableName)
+		createSql := strings.Replace(createTableStr, tmpName, tableName, -1)
+		log.Println(createSql)
+		_, err := a.JyMysql.ExecBySql(createSql)
+		if err == nil {
+			log.Println(tableName, "执行成功")
+		} else {
+			log.Println(tableName, "执行失败", err)
+		}
+	}
+
+}

doc/bulkCreateTable/说明.txt

@@ -0,0 +1 @@
+批量执行sql程序用户判重表的创建和变更