自己如何写mysql数据库_自己手写的一个初始化MySQL数据库的工具！

由于项目需要&＃xff0c;我写了一个初始MySQL数据库的工具&＃xff1b;

一&＃xff0c; 思路&＃xff1a;

(1)&＃xff0c;首先读取包含mysql语句的脚本(其中有创建数据库&＃xff0c;表&＃xff0c;插入初始数据等&＃xff01;)。

(2)&＃xff0c;然后替换里面的一些数据值(如guid&＃xff0c;注释等&＃xff01;)。

(3)&＃xff0c;把替换后的数据流重新写入mysql脚本。

(4)&＃xff0c;调用MySQL命令执行相应的命令。

主要思路结束&＃xff01;

二&＃xff0c;   现具体过程如下&＃xff1a;

1&＃xff0c;主界面如图&＃xff1a;

2&＃xff0c;全局代码和构造方法如下&＃xff1a;

CodestringIP;

stringuserName;

stringuserPwd;

stringpath;

stringmesg&＃61;"";

        Boolean info&＃61;false;

//字符串形式的guidstring_guID&＃61;"";

stringtimeMesg&＃61;"";

inti&＃61;0;

//测量间隔运行时间Stopwatch stop&＃61;newStopwatch();

publicToolForm()

{

            InitializeComponent();

        }

3&＃xff0c;在按钮事件中验证了各个文本框中的值是否为空&＃xff1b;IP地址和端口号的验证&＃xff01;

代码如下&＃xff1a;

Code

/**///按钮事件

/////////

privatevoidbtnOK_Click(objectsender, EventArgs e)

{

            i&＃61;0;

this.lbMessage.Text&＃61;"";

            IP&＃61;this.tbIP.Text.Trim();

            userName&＃61;this.tbUserName.Text.Trim();

            userPwd&＃61;this.tbPWD.Text.Trim();

            DirPath&＃61;Application.StartupPath;

            Regex regexIP&＃61;newRegex(&＃64;"^((0|1[0-9]{0,2}|2[0-9]{0,1}|2[0-4][0-9]|25[0-5]|[3-9][0-9]{0,1})\.){3}(0|1[0-9]{0,2}|2[0-9]{0,1}|2[0-4][0-9]|25[0-5]|[3-9][0-9]{0,1})$");

if(string.IsNullOrEmpty(IP))

{

                MessageBox.Show("请输入服务器地址!");

this.tbIP.Focus();

return;

            }elseif(string.IsNullOrEmpty(userName))

{

                MessageBox.Show("请输入用户名!");

this.tbUserName.Focus();

return;

            }elseif(string.IsNullOrEmpty(userPwd))

{

                MessageBox.Show("请输入密码!");

this.tbPWD.Focus();

return;

            }elseif(regexIP.IsMatch(IP)||(string.Compare(IP,"localhost",true)&＃61;&＃61;0))

{

//得到目录下的所有文件string[] files&＃61;Directory.GetFiles(DirPath);

//循环读文件foreach(stringfileinfiles)

{

//如果后缀名为.sql文件if(".sql".IndexOf(file.Substring(file.LastIndexOf(".")&＃43;1))>-1)

{

//把.sql文件全名加人到fileList集合中fileList.Add(file);

                    }                }

if(fileList.Count>1)

{

                    MessageBox.Show("目录下多个.sql文件&＃xff01;该程序只能读一个&＃xff01;");

return;

                }elseif(fileList.Count<1)

{

                    MessageBox.Show("目录下没有.sql文件&＃xff01;");

return;

                }else

{

                    path&＃61;fileList.First();

this.lbMessage.Text&＃61;"正在导入数据&＃xff01;请稍等

..";

//测量时间开始stop.Start();

//调用主方法MainMethod();

                }            }else

{

                MessageBox.Show("服务器IP地址不规范&＃xff01;");

this.tbIP.Focus();

return;

            }           

        }

4&＃xff0c; 如果输入符和规范&＃xff0c;则调用主方法(主方法里实现思路中主要方法的调用)&＃xff1b;

主方法代码如下&＃xff1a;

Code

/**///主方法

//////////////////

privatevoidMainMethod()

{

try

{

//读文件stringfileRed&＃61;ReadSQLFromFile(path);

//写文件File.WriteAllText(path, fileRed);

//调用进度条的timerthis.timer1.Start();

//调用执行脚本文件的timerthis.timer2.Start();

            }catch(Exception ex)

{

                MessageBox.Show(ex.Message);

            }

        }

5&＃xff0c;    读脚本文件&＃xff0c;替换guid标识的方法&＃xff1b;

代码如下&＃xff1a;

Code

/**///读文件流,替换guid标示

////////////

privatestringReadSQLFromFile(stringpath)

{

//新生成一个guidGuid guId&＃61;Guid.NewGuid();

//把guid转换为字符串形式的guid_guID&＃61;"{"&＃43;guId&＃43;"}";

            FileStream fs&＃61;null;

stringstrQuery&＃61;"";

try

{

                fs&＃61;newFileStream(path, FileMode.Open, FileAccess.Read);

stringstrTemp&＃61;Encoding.UTF8.GetString(ConvertStreamToByteBuffer(fs));

//用新生成的guid替换掉脚本文件中的guid;strQuery&＃61;Regex.Replace(strTemp,&＃64;"(\{[A-Fa-f0-9]{8}(-[A-Fa-f0-9]{4}){3}-[A-Fa-f0-9]{12}\})&＃43;", _guID, RegexOptions.Singleline);

intindexValue&＃61;strQuery.IndexOf("USE")&＃43;3;

intindexStart&＃61;indexValue;

intindexEnd&＃61;0;

while(strQuery.Substring(indexValue,1)!&＃61;";")

{

                    indexValue&＃43;&＃43;;

                    indexEnd&＃61;indexValue;

                }                DBName&＃61;strQuery.Substring(indexStart, (indexEnd-indexStart));

            }catch(Exception ex)

{

                MessageBox.Show(ex.Message);

                strQuery&＃61;"";

            }finally

{

                fs.Close();

            }           

returnstrQuery;

        }

6&＃xff0c;把替换后的字符串写入脚本文件&＃xff1a;

代码如下&＃xff1a;

CodeFile.WriteAllText(path, fileRed);

7&＃xff0c;然后是开启两个timer&＃xff0c;一个控制进度条&＃xff0c;另一个获取执行时间的间隔。这里略。。。

8&＃xff0c;在获取执行时间的timer事件中&＃xff0c;调用执行脚本文件的方法。

该方法的代码如下&＃xff1a;

Code

/**///调用mysql命令来执行脚本文文件

//////////////////

publicstringRunCmd()

{

            Stopwatch a&＃61;newStopwatch();

longm&＃61;a.ElapsedMilliseconds;

stringmesg&＃61;"";

stringmesgError&＃61;"";

            Process p&＃61;null;

try

{

进入cmd调用mysql命令来执行脚本文件#region进入cmd调用mysql命令来执行脚本文件                p&＃61;newProcess();

                p.StartInfo.FileName&＃61;"cmd.exe";

                p.StartInfo.UseShellExecute&＃61;false;

                p.StartInfo.RedirectStandardInput&＃61;true;

                p.StartInfo.RedirectStandardOutput&＃61;true;

                p.StartInfo.RedirectStandardError&＃61;true;

                p.StartInfo.CreateNoWindow&＃61;true;

                p.Start();

//p.StandardInput.WriteLine(&＃64;"net start mysql");p.StandardInput.WriteLine(&＃64;"c:");

                p.StandardInput.WriteLine(&＃64;"cd C:\Program Files\MySQL\MySQL Server 5.0\bin");

                p.StandardInput.WriteLine(string.Format("mysql.exe -h{0} -u{1} -p{2} -f{3}\"", IP, userName, userPwd, path));

                p.StandardInput.WriteLine("exit");

                mesgError&＃61;p.StandardError.ReadToEnd();

                mesg&＃61;mesgError;

                p.WaitForExit();

#endregion            }catch(Exception err)

{

//MessageBox.Show(err.Message);//显示错误信息。mesg&＃61;err.Message;

            }finally

{

                p.Close();

            }returnmesg;

        }

9,把给定的文件流转换为二进制字节数组的方法,

代码如下:

Code

把给定的文件流转换为二进制字节数组byte[] ConvertStreamToByteBuffer(System.IO.Stream theStream)#region把给定的文件流转换为二进制字节数组byte[] ConvertStreamToByteBuffer(System.IO.Stream theStream)

/**///把给定的文件流转换为二进制字节数组。

/////////

publicbyte[] ConvertStreamToByteBuffer(System.IO.Stream theStream)

{

intb1;

            System.IO.MemoryStream tempStream&＃61;newSystem.IO.MemoryStream();

while((b1&＃61;theStream.ReadByte())!&＃61;-1)

{

                tempStream.WriteByte(((byte)b1));

            }returntempStream.ToArray();

        }#endregion

10,控制进度条的timer事件;

代码如下:

Code//控制进度条显示/privatevoidtimer1_Tick(objectsender, EventArgs e)

{try{this.progressBar1.Value&＃61;i;

i&＃43;&＃61;10;if(i&＃61;&＃61;1000)

{this.timer1.Stop();if(string.IsNullOrEmpty(mesg)&&info)

{

lbMessage.Text&＃61;"数据导入成功&＃xff01;"&＃43;timeMesg;newMCFrom(_guID, IP, userName, userPwd, DBName).ShowDialog();

}else{

lbMessage.Text&＃61;"数据导入失败&＃xff01;";

}

stop.Reset();

}

}catch(System.Exception )

{

}

}

11,获取执行时间间隔的time事件;

代码如下:

Code

/**///调用执行脚本文件的方法&＃xff0c;并得到从点击按钮到成功导入数据库后的间隔时间。

/////////

privatevoidtimer2_Tick(objectsender, EventArgs e)

{

//执行文件中的命令mesg&＃61;RunCmd();

this.timer2.Stop();

            info&＃61;true;

            timeMesg&＃61;stop.Elapsed.Seconds.ToString()&＃43;"秒";

            stop.Stop();

        }

12,整个小工具大体的程序代码完成&＃xff01;有些细节省略掉了 &＃xff01;请在我的随笔里查看&＃xff01;