当前位置:首页 » 操作系统 » java备份mysql数据库

java备份mysql数据库

发布时间: 2022-05-01 01:42:17

java 备份mysql数据库

备份MySQL数据库的方法:
import java.io.File;
import java.io.IOException;

/**
* MySQL数据库备份
*
* @author GaoHuanjie
*/
public class MySQLDatabaseBackup {

/**
* Java代码实现MySQL数据库导出
*
* @author GaoHuanjie
* @param hostIP MySQL数据库所在服务器地址IP
* @param userName 进入数据库所需要的用户名
* @param password 进入数据库所需要的密码
* @param savePath 数据库导出文件保存路径
* @param fileName 数据库导出文件文件名
* @param databaseName 要导出的数据库名
* @return 返回true表示导出成功,否则返回false。
*/
public static boolean exportDatabaseTool(String hostIP, String userName, String password, String savePath, String fileName, String databaseName) {
File saveFile = new File(savePath);
if (!saveFile.exists()) {// 如果目录不存在
saveFile.mkdirs();// 创建文件夹
}
if (!savePath.endsWith(File.separator)) {
savePath = savePath + File.separator;
}

StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append("mysqlmp").append(" --opt").append(" -h").append(hostIP);
stringBuilder.append(" --user=").append(userName) .append(" --password=").append(password).append(" --lock-all-tables=true");
stringBuilder.append(" --result-file=").append(savePath + fileName).append(" --default-character-set=utf8 ").append(databaseName);
try {
Process process = Runtime.getRuntime().exec(stringBuilder.toString());
if (process.waitFor() == 0) {// 0 表示线程正常终止。
return true;
}
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
return false;
}

public static void main(String[] args) throws InterruptedException {
if (exportDatabaseTool("172.16.0.127", "root", "123456", "D:/backupDatabase", "2014-10-14.sql", "test")) {
System.out.println("数据库备份成功!!!");
} else {
System.out.println("数据库备份失败!!!");
}
}
}

⑵ 求一个能实现mysql数据备份的程序,要Java代码

备份数据库:(将数据库test备份)
mysqlmp
-u
root
-p
test>c:\test.txt
将备份数据导入到数据库:(导回test数据库)
mysql
-u
root
-p
test<c:\test.txt

⑶ java mysql备份数据库数据问题

想得到所有记录及表的sql语句?

将框里面那句删除了试试

插不上图

System.out.println(result+"--");

这句删除掉试试

⑷ 怎么用java备份mysql数据库

首先,设置mysql的环境变量(在path中添加%MYSQL_HOME%\bin),重启电脑。
完整代码:
备份:

public static void main(String[] args) {

backup();
load();
}

public static void backup() {
try {
Runtime rt = Runtime.getRuntime();

// 调用 mysql 的 cmd:
Process child = rt
.exec("mysqlmp -u root --set-charset=utf8 bjse act_obj");// 设置导出编码为utf8。这里必须是utf8

// 把进程执行中的控制台输出信息写入.sql文件,即生成了备份文件。注:如果不对控制台信息进行读出,则会导致进程堵塞无法运行
InputStream in = child.getInputStream();// 控制台的输出信息作为输入流

InputStreamReader xx = new InputStreamReader(in, "utf8");// 设置输出流编码为utf8。这里必须是utf8,否则从流中读入的是乱码

String inStr;
StringBuffer sb = new StringBuffer("");
String outStr;
// 组合控制台输出信息字符串
BufferedReader br = new BufferedReader(xx);
while ((inStr = br.readLine()) != null) {
sb.append(inStr + "\r\n");
}
outStr = sb.toString();

// 要用来做导入用的sql目标文件:
FileOutputStream fout = new FileOutputStream(
"e:/mysql-5.0.27-win32/bin/bjse22.sql");
OutputStreamWriter writer = new OutputStreamWriter(fout, "utf8");
writer.write(outStr);
// 注:这里如果用缓冲方式写入文件的话,会导致中文乱码,用flush()方法则可以避免
writer.flush();

// 别忘记关闭输入输出流
in.close();
xx.close();
br.close();
writer.close();
fout.close();

System.out.println("");

} catch (Exception e) {
e.printStackTrace();
}

}

public static void load() {
try {
String fPath = "e:/mysql-5.0.27-win32/bin/bjse22.sql";
Runtime rt = Runtime.getRuntime();

// 调用 mysql 的 cmd:
Process child = rt.exec("mysql -u root bjse ");
OutputStream out = child.getOutputStream();//控制台的输入信息作为输出流
String inStr;
StringBuffer sb = new StringBuffer("");
String outStr;
BufferedReader br = new BufferedReader(new InputStreamReader(
new FileInputStream(fPath), "utf8"));
while ((inStr = br.readLine()) != null) {
sb.append(inStr + "\r\n");
}
outStr = sb.toString();

OutputStreamWriter writer = new OutputStreamWriter(out, "utf8");
writer.write(outStr);
// 注:这里如果用缓冲方式写入文件的话,会导致中文乱码,用flush()方法则可以避免
writer.flush();
// 别忘记关闭输入输出流
out.close();
br.close();
writer.close();

System.out.println("");

} catch (Exception e) {
e.printStackTrace();
}

}

备份语句:
mysql> SELECT * INTO OUTFILE "D:\\data\\db_testtemp.txt" fields terminated by ',
' from db_testtemp where std_state='1';
Query OK, 1 row affected (0.00 sec)

mysql> SELECT * INTO OUTFILE "D:\\data\\db_testtemp.txt" fields terminated by ',
' from db_testtemp ;
Query OK, 2 rows affected (0.00 sec)

只生成一个只有数据的.txt:SELECT * INTO OUTFILE "D:\\data\\db_testtemp.txt" fields terminated by ',' lines terminated by '\r\n' from db_testtemp ;

只生成一个只有数据的.txt:mysqlmp -uroot -pncae2010 -w "std_state='1'" -T D:\data --no-create-info --fields-terminated-by=, exam db_testtemp

生成一个创建数据库语句的.sql,一个只有数据的.txt:mysqlmp -uroot -pncae2010 -w "std_state='1'" -T D:\data --fields-terminated-by=, exam db_testtemp

只生成insert语句:mysqlmp -uroot -pncae2010 -w "std_state='1'" -t exam db_testtemp > D:\data\a.sql

⑸ java 备份mysql数据库的部分数据

假设;你要备份的数据条件是时间,只备份当天的数据。备份区:数据库。

  1. 匹配当天的数据读出来。

  2. 在将数据添加到备份区的数据库。

备份区表的创建问题:1.你可以事先手动建好。

2.也可以通过程序自动建表有两步;

a).判断当前备份数据,在备份区是否有对应的表。(有直接添加)

b).如果没有,拷贝当前备份数据的表结构,在备份区生成。

⑹ java备份mysql数据问题, 无法找到库,错误信息如下

楼主可以直接使用mysql的导出导入命令来进行数据库的备份和还原


将MySQL添加到环境变量中,然后在cmd命令行中执行[将C:ProgramFilesMySQLMySQL Server 5.5in加到系统变量的path中或到C:ProgramFilesMySQLMySQL Server 5.5in文件夹中去执行命令]。


导出数据:

mysqlmp-h127.0.0.1-uroot-p123456--add-drop-table-Rald>e:	estdb.sql

127.0.0.1是ip地址,root是用户,123456是密码,ald是数据库名称,e: estdb.sql导出文件路径


导入数据:

mysql-h127.0.0.1-uroot-p123456--default-character-set=utf8ald<e:	estdb.sql

⑺ javaweb如何备份数据库

类JavaMysql备份还原数据库

importjava.io.File;
importjava.io.IOException;
importjava.io.InputStream;
importjava.util.Properties;

publicclassJavaMysql{
/*
*备份数据库1、读取配置文件2、启动智能查询Mysql安装目录3、备份数据库为sql文件
*/
publicstaticvoidbackup(Stringsql){

Propertiespros=getPprVue("prop.properties");
Stringusername=pros.getProperty("username");
Stringpassword=pros.getProperty("password");

CheckSoftwarec=null;
try{
System.out.println("MySQL服务安装地址:"+c.check().toString());
}catch(Exceptione2){
e2.printStackTrace();
}
Stringmysqlpaths;
try{
mysqlpaths=c.check().toString()+"bin"+"\";

StringdatabaseName=pros.getProperty("databaseName");
Stringaddress=pros.getProperty("address");
Stringsqlpath=pros.getProperty("sql");
Filebackupath=newFile(sqlpath);
if(!backupath.exists()){
backupath.mkdir();
}

StringBuffersb=newStringBuffer();

sb.append(mysqlpaths);
sb.append("mysqlmp");
sb.append("--opt");
sb.append("-h");
sb.append(address);
sb.append("");
sb.append("--user=");
sb.append(username);
sb.append("");
sb.append("--password=");
sb.append(password);
sb.append("");
sb.append("--lock-all-tables=true");
sb.append("--result-file=");
sb.append(sqlpath);
sb.append(sql);
sb.append("");
sb.append("--default-character-set=utf8");
sb.append(databaseName);
System.out.println("cmd指令:"+sb.toString());
Runtimecmd=Runtime.getRuntime();
try{
Processp=cmd.exec(sb.toString());
}catch(IOExceptione){
e.printStackTrace();
}
}catch(Exceptione1){
e1.printStackTrace();
}
}

/*
*读取属性文件
*/
(StringproperName){

InputStreaminputStream=JavaMysql.class.getClassLoader()
.getResourceAsStream(properName);
Propertiesp=newProperties();

try{
p.load(inputStream);
inputStream.close();
}catch(IOExceptione){
e.printStackTrace();
}

returnp;

}

/*
*根据备份文件恢复数据库
*/
publicstaticvoidload(Stringfilename){
Propertiespros=getPprVue("prop.properties");
Stringroot=pros.getProperty("jdbc.username");
Stringpass=pros.getProperty("jdbc.password");
Stringmysqlpaths=c.check().toString()+"bin"+"\";
Stringsqlpath=pros.getProperty("sql");
Stringfilepath=mysqlpaths+sqlpath+filename;//备份的路径地址

Stringstmt1=mysqlpaths+"mysqladmin-u"+root+"-p"+pass
+"createfinacing";//-p后面加的是你的密码
Stringstmt2=mysqlpaths+"mysql-u"+root+"-p"+pass
+"finacing<"+filepath;
String[]cmd={"cmd","/c",stmt2};
try{
Runtime.getRuntime().exec(stmt1);
Runtime.getRuntime().exec(cmd);
System.out.println("数据已从"+filepath+"导入到数据库中");
}catch(IOExceptione){
e.printStackTrace();
}

}

/*
*Test测试
*/
publicstaticvoidmain(String[]args)throwsIOException{
backup("2221.sql");
}
}

⑻ java用MySql 单击备份按钮实现备份该怎么写啊!

首先设置mysql环境变量

package com.vote.utils;

import java.io.File;
import java.io.IOException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

public class BackupMysql {

public static void main(String[] args) {
//new Backup().start();
//new Recovery().start();
}

static class Backup extends Thread {
public void run() {
String user = "root"; // Database Account
String password = "root"; // Login Password
String database = "数据库"; // Need to back up the Database name
String filepath = "d:\\数据库bak\\" + getFileName(database,".bak"); // Address of the backup path
File savefile = new File("d:\\数据库bak\\", "aa.txt");
if(!savefile.getParentFile().exists()) savefile.getParentFile().mkdirs();
String command = "mysqlmp " + database + " -h localhost " + " -u " + user + " -p" + password + " --default-character-set=utf8 --result-file=" + filepath;
try {
Runtime.getRuntime().exec(command);
System.out.println("Successful data backup of " + database);
}catch(IOException e) {
e.printStackTrace();
}
}
private String getFileName(String soure,String suffix) {
String fileName = null;
DateFormat df = new SimpleDateFormat(".yyyy.MM.dd.hh.mm.ss.");
String dfs = df.format(new Date());
String rans = ((int)(Math.random() * 100) + 1) + "";
int rlen = rans.length();
if(rlen == 1){
rans = "0" + rans;
}
fileName = soure + dfs + Integer.toHexString(Integer.parseInt(rans)) + suffix;
return fileName;
}
}

static class Recovery extends Thread {
public void run() {
String user = "root"; // Database Account
String password = "root"; // Login Password
String database = "数据库"; // Need to back up the Database name
String filepath = "d:\\数据库bak\\数据库.2011.10.27.12.56.04.50.bak"; // Address of the recovery path
String command = " -h localhost " + " -u " + user + " -p" + password;
String cmd[] = {"cmd","/c","mysql " + command + " " + database + " < " + filepath};
try {
Runtime.getRuntime().exec("mysqladmin " + command + " create " + database);
Runtime.getRuntime().exec(cmd);
}catch(IOException e) {
e.printStackTrace();
}
}
}

}

⑼ 如何使用java程序备份和恢复MySql数据库

java用开源的ssh jar包连接到b服务器执行备份/恢复命令,同样通过命令也可以获取到备份的文件信息,恢复数据库也是一样的,通过命令把文件传输到b服务器,通过命令进行还原

⑽ 如何用Java实现MySQL数据库的备份和恢复

注:要将mysql的bin目录加入到环境变量Path中
将MySql中的数据库导出到文件中 备份
import java.io.*;
import java.lang.*;
public class BeiFen {
public static void main(String[] args) {
// 数据库导出
String user = "root"; // 数据库帐号
String password = "root"; // 登陆密码
String database = "test"; // 需要备份的数据库名
String filepath = "e:\\test.sql"; // 备份的路径地址
String stmt1 = "mysqlmp " + database + " -u " + user + " -p"
+ password + " --result-file=" + filepath;
/*
* String mysql="mysqlmp test -u root -proot
* --result-file=d:\\test.sql";
*/
try {
Runtime.getRuntime().exec(stmt1);
System.out.println("数据已导出到文件" + filepath + "中");
}
catch (IOException e) {
e.printStackTrace();
}
}
}

将数据从磁盘上的文本文件还原到MySql中的数据库
import java.io.*;
import java.lang.*;

/*
* 还原MySql数据库
* */
public class Recover {

public static void main(String[] args) {

String filepath = "d:\\test.sql"; // 备份的路径地址
//新建数据库test
String stmt1 = "mysqladmin -u root -proot create test";
String stmt2 = "mysql -u root -proot test < " + filepath;
String[] cmd = { "cmd", "/c", stmt2 };

try {
Runtime.getRuntime().exec(stmt1);
Runtime.getRuntime().exec(cmd);
System.out.println("数据已从 " + filepath + " 导入到数据库中");
} catch (IOException e) {
e.printStackTrace();
}
}
}

热点内容
我的世界好玩服务器拍视频 发布:2024-10-05 13:23:19 浏览:553
穿越火线挂机脚本 发布:2024-10-05 13:05:44 浏览:33
分解质因数c语言 发布:2024-10-05 12:15:53 浏览:777
mysql存储过程字符编码 发布:2024-10-05 12:05:48 浏览:182
c语言命名 发布:2024-10-05 11:56:38 浏览:617
编程哪个好学习 发布:2024-10-05 11:50:59 浏览:1000
为什么不买安卓旗舰 发布:2024-10-05 11:46:04 浏览:382
ostcb编译条件 发布:2024-10-05 11:28:24 浏览:993
win10怎么关闭登录密码 发布:2024-10-05 11:09:55 浏览:936
降温解压器 发布:2024-10-05 10:54:15 浏览:422