mysql恢復資料庫代碼(mysql文件恢復資料庫)

本文目錄一覽:

mysql資料庫沒用備份如何恢復

打開mysql的bin log功能:

對於mysql也是支持增量備份,但要打開mysql的bin log功能。

我們修改mysql的配置文件。linux是/etc/my.cnf,windows是mysql的安裝目錄/my.ini

我們在[mysqld]下面加上log-bin一行代碼,如下面。

[mysqld]

log-bin=mysql-bin

複製代碼

加完後重起mysql即可。

某客戶更新數據的時候,誤刪了資料庫的內容,因為資料庫做了主從,但是沒有做備份(備份很重要啊!)幸好開啟了bin-log,之後只好把整個日誌的記錄拿回來本地進行恢復。

之後自己也做了一個簡單的測試,對數據進行恢復,具體如下:

1、新建一個表

CREATE TABLE `lynn`.`sn_test` ( `name` VARCHAR( 10 ) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL , `age` INT( 3 ) NOT NULL ) ENGINE = MYISAM;

2、插入多條數據

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn1’, ‘1’);

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn2’, ‘2’);

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn3’, ‘3’);

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn4’, ‘4’);

3、查看數據並刪除

mysql select * from sn_test;

+——-+—–+

| name | age |

+———+—+

| lynn1 | 1 |

| lynn2 | 2 |

| lynn3 | 3 |

| lynn4 | 4 |

+———+—–+

4 rows in set (0.00 sec)

mysql delete from sn_test;

Query OK, 4 rows affected (0.00 sec)

mysql select * from sn_test;

Empty set (0.00 sec)

4、mysqlbinlog恢複數據

mysqlbinlog mysql-bin.000006 1.sql

查看1.txt裡面數據插入的紀錄,把刪除之前的數據進行恢復

mysqlbinlog mysql-bin.000006 –start-position=2471 –stop-position=2876 | mysql -uroot -p123

重新登錄,查看數據,OK,已經成功恢復了

對於資料庫操作,應該注意如下問題:

1、要常備份(全備,增量備份),出了問題可以最快恢複數據;

2、操作資料庫前,要把需要操作的資料庫或者表dump出來;

3、需要把bin-log打開,就算沒有做上面的兩步,也可以通過日誌恢複數據

mysql刪除資料庫沒有備份怎麼恢復

打開mysql的bin log功能:

對於mysql也是支持增量備份,但要打開mysql的bin log功能。

我們修改mysql的配置文件。linux是/etc/my.cnf,windows是mysql的安裝目錄/my.ini

我們在[mysqld]下面加上log-bin一行代碼,如下面。

[mysqld]

log-bin=mysql-bin

複製代碼

加完後重起mysql即可。

某客戶更新數據的時候,誤刪了資料庫的內容,因為資料庫做了主從,但是沒有做備份(備份很重要啊!)幸好開啟了bin-log,之後只好把整個日誌的記錄拿回來本地進行恢復。

之後自己也做了一個簡單的測試,對數據進行恢復,具體如下:

1、新建一個表

CREATE TABLE `lynn`.`sn_test` ( `name` VARCHAR( 10 ) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL , `age` INT( 3 ) NOT NULL ) ENGINE = MYISAM;

2、插入多條數據

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn1’, ‘1’);

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn2’, ‘2’);

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn3’, ‘3’);

INSERT INTO `lynn`.`sn_test` (`name`, `age`) VALUES (‘lynn4’, ‘4’);

3、查看數據並刪除

mysql select * from sn_test;

+——-+—–+

| name | age |

+———+—+

| lynn1 | 1 |

| lynn2 | 2 |

| lynn3 | 3 |

| lynn4 | 4 |

+———+—–+

4 rows in set (0.00 sec)

mysql delete from sn_test;

Query OK, 4 rows affected (0.00 sec)

mysql select * from sn_test;

Empty set (0.00 sec)

4、mysqlbinlog恢複數據

mysqlbinlog mysql-bin.000006 1.sql

查看1.txt裡面數據插入的紀錄,把刪除之前的數據進行恢復

mysqlbinlog mysql-bin.000006 –start-position=2471 –stop-position=2876 | mysql -uroot -p123

重新登錄,查看數據,OK,已經成功恢復了

對於資料庫操作,應該注意如下問題:

1、要常備份(全備,增量備份),出了問題可以最快恢複數據;

2、操作資料庫前,要把需要操作的資料庫或者表dump出來;

3、需要把bin-log打開,就算沒有做上面的兩步,也可以通過日誌恢複數據

如何修復MySQL資料庫

1、mysqlcheck 進行表修復

使用mysqlcheck 命令對錶進行修復

#mysqlcheck -uuser -ppassword database table -c #檢查單個表是否損壞

#mysqlcheck -uuser -ppassword database -c #檢查整個庫那些表損壞

首先檢查資料庫的那些表損壞,如果能定位到那張表損壞可以直接對錶修復

#mysqlcheck -uuser -ppassword database table -r # 修複數據表

#mysqlcheck -uuser -ppassword database -r # 修復整個資料庫

更多參數 查看 mysqlcheck –help

2、myisamchk 修復mysql表

Myisamchk是MyISAM表維護的一個非常實用的工具。可以使用myisamchk實用程序來獲得有關資料庫表的信息或檢查、修復、優化他們。myisamchk適用MyISAM表(對應.MYI和.MYD文件的表)。

怎麼還原,恢復或導入MySQL資料庫

1、source命令

1)打開開始菜單-程序-MySQL-MySQL Command Line Client,輸入MySQL的root密碼。

2)然後輸入use 資料庫名;進入對應的資料庫,再用source 備份文件具體路徑;命令導入備份文件。注意,在這裡的命令後面都要加;分號,截圖如下:

2、mysql命令

1)如果是Windows系統,請在命令行模式下進入mysql的bin目錄,如D:\Program\mysql41\bin。如果是Linux系統,請直接看下面的步驟。

2)執行mysql命令導入資料庫,命令格式為:

mysql -u用戶名 -p密碼 資料庫名備份文件具體路徑

比如:mysql -uroot -pabc123 mydbfile.sql,其中用戶名和密碼也可以是具體資料庫的,不一定要root的。

二、資料庫的導出(備份)

一般使用mysqldump命令

1)如果是Windows系統,請在命令行模式下進入mysql的bin目錄,如D:\Program\mysql41\bin。如果是Linux系統,請直接看下面的步驟。

2)執行mysqldump命令導入資料庫,命令格式為:

mysqldump -u用戶名 -p密碼 資料庫名備份文件具體路徑

如何用Java實現MySQL資料庫的備份和恢復

MySQL的一些前台工具是有備份恢復功能的,可是如何在我們的應用程序中實現這一功能呢?本文提供了示例代碼來說明如何使用Java代碼實現MySQL資料庫的備份恢復。

本次實現是使用了MySQL資料庫本身提供的備份命令mysqldump和恢復命令mysql,在java代碼中通過從命令行調用這兩條命令來實現備份和恢復。備份和恢復所使用的文件都是sql文件。

本代碼是參照網上某網友提供的源碼完成的。

[java] view plaincopy

package xxx.utils;

import java.io.BufferedReader;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.io.UnsupportedEncodingException;

/**

* MySQL資料庫的備份與恢復 缺陷:可能會被殺毒軟體攔截

*

* @author xxx

* @version xxx

*/

public class DatabaseBackup {

/** MySQL安裝目錄的Bin目錄的絕對路徑 */

private String mysqlBinPath;

/** 訪問MySQL資料庫的用戶名 */

private String username;

/** 訪問MySQL資料庫的密碼 */

private String password;

public String getMysqlBinPath() {

return mysqlBinPath;

}

public void setMysqlBinPath(String mysqlBinPath) {

this.mysqlBinPath = mysqlBinPath;

}

public String getUsername() {

return username;

}

public void setUsername(String username) {

this.username = username;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password = password;

}

public DatabaseBackup(String mysqlBinPath, String username, String password) {

if (!mysqlBinPath.endsWith(File.separator)) {

mysqlBinPath = mysqlBinPath + File.separator;

}

this.mysqlBinPath = mysqlBinPath;

this.username = username;

this.password = password;

}

/**

* 備份資料庫

*

* @param output

* 輸出流

* @param dbname

* 要備份的資料庫名

*/

public void backup(OutputStream output, String dbname) {

String command = “cmd /c ” + mysqlBinPath + “mysqldump -u” + username

+ ” -p” + password + ” –set-charset=utf8 ” + dbname;

PrintWriter p = null;

BufferedReader reader = null;

try {

p = new PrintWriter(new OutputStreamWriter(output, “utf8”));

Process process = Runtime.getRuntime().exec(command);

InputStreamReader inputStreamReader = new InputStreamReader(process

.getInputStream(), “utf8”);

reader = new BufferedReader(inputStreamReader);

String line = null;

while ((line = reader.readLine()) != null) {

p.println(line);

}

p.flush();

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

if (reader != null) {

reader.close();

}

if (p != null) {

p.close();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

/**

* 備份資料庫,如果指定路徑的文件不存在會自動生成

*

* @param dest

* 備份文件的路徑

* @param dbname

* 要備份的資料庫

*/

public void backup(String dest, String dbname) {

try {

OutputStream out = new FileOutputStream(dest);

backup(out, dbname);

} catch (FileNotFoundException e) {

e.printStackTrace();

}

}

/**

* 恢復資料庫

*

* @param input

* 輸入流

* @param dbname

* 資料庫名

*/

public void restore(InputStream input, String dbname) {

String command = “cmd /c ” + mysqlBinPath + “mysql -u” + username

+ ” -p” + password + ” ” + dbname;

try {

Process process = Runtime.getRuntime().exec(command);

OutputStream out = process.getOutputStream();

String line = null;

String outStr = null;

StringBuffer sb = new StringBuffer(“”);

BufferedReader br = new BufferedReader(new InputStreamReader(input,

“utf8”));

while ((line = br.readLine()) != null) {

sb.append(line + “/r/n”);

}

outStr = sb.toString();

OutputStreamWriter writer = new OutputStreamWriter(out, “utf8”);

writer.write(outStr);

writer.flush();

out.close();

br.close();

writer.close();

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

/**

* 恢復資料庫

*

* @param dest

* 備份文件的路徑

* @param dbname

* 資料庫名

*/

public void restore(String dest, String dbname) {

try {

InputStream input = new FileInputStream(dest);

restore(input, dbname);

} catch (FileNotFoundException e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

Configuration config = HibernateSessionFactory.getConfiguration();

String binPath = config.getProperty(“mysql.binpath”);

String userName = config.getProperty(“connection.username”);

String pwd = config.getProperty(“connection.password”);

DatabaseBackup bak = new DatabaseBackup(binPath, userName, pwd);

bak.backup(“c:/ttt.sql”, “ttt”);

bak.restore(“c:/ttt.sql”, “ttt”);

}

}

最後的main方法只是一個簡單的使用方法的示例代碼。

本人所做的項目是使用了hibernate的,而這裡需要提供MySQL的bin路徑和用戶名、密碼,而hibernate.cfg.xml中本身就是需要配置資料庫的用戶名和密碼,所以我把MySQL的bin路徑也直接配置到了這個文件裡面,也不需要創建專門的配置文件,不需要寫讀取配置文件的介面了。

如果不明白,可以去看hibernate.cfg.xml的說明,裡面是可以配置其他的property的

原創文章,作者:簡單一點,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/127716.html

(0)
打賞 微信掃一掃 微信掃一掃 支付寶掃一掃 支付寶掃一掃
簡單一點的頭像簡單一點
上一篇 2024-10-03 23:16
下一篇 2024-10-03 23:16

相關推薦

發表回復

登錄後才能評論