本文目錄一覽：
怎樣用java連接mysql
//就只有4個步驟：1.加載驅動;2.鏈接數據庫;3.執行命令；4.關閉數據庫;
import java.sql.*;
class MysqlConnection
{
/*要是更換數據庫，就直接更換這些語句就行了，main函數的那些都不用動的，主要是驅動(DBDRIVER)和鏈接方式(DBURL)*/
private static String DBDRIVER = “org.gjt.mm.mysql.Driver”;//這個是與下載jdbc-mysql裡面的那個driver.class文件是對應的，你
//可以解壓找下，會發覺驅動就是那個鬼東西的。。
private static String DBURL = “jdbc:mysql://localhost:3306/study”;/*
jdbc:mysql://localhost:3306:test這句裡面分如下解析：
jdbc:mysql:// 是指JDBC連接方式；
localhost: 是指你的本機地址；
3306 SQL數據庫的端口號；
study 就是你要連接的數據庫的地址。
你可以試下不要這個’study’，或者胡亂接一個不存在的數據庫，
然後還可以執行下面語句來實現連接數據庫（a）
*/
private static String DBUSER = “scott”;
private static String DBPASSWORD = “tiger”;
public static void main(String[] args)throws Exception
{
Class.forName(DBDRIVER);//1.加載驅動
Connection conn = DriverManager.getConnection(DBURL,DBUSER,DBPASSWORD);//2.獲得鏈接
Statement statement = conn.createStatement();//3.執行命令
//statement.executeUpdate(“use study”);//(a)要是沒有上面的那個數據庫，就要使用這個函數來連接數據庫
ResultSet result = statement.executeQuery(“SELECT * FROM emp”);//結果收集，迭代
while(result.next()){
printf(result.getObject(1)+” “);
printf(result.getObject(2)+” “);
printf(result.getObject(3)+” “);
printf(result.getObject(4)+”\n”);
}
conn.close();
}
public static void printf(Object obj){
System.out.print(obj);
}
public static void printfln(Object obj){
System.out.println(obj);
}
}
如何用Java實現MySQL數據庫的備份和恢復
如何用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 = “mysqldump ” + database + ” -u ” + user + ” -p”
+ password + ” –result-file=” + filepath;
/*
* String mysql=”mysqldump 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();
}
}
}
怎麼用java實現mysql數據庫的導入導出
使用Java實現對MySql數據庫的導入與導出
package com.project.ajaxs;
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.util.Calendar;
import java.util.Date;
public class BakMysql {
//main的方法，主要是我用於測試的，是想着取得CLASS的路徑，然後備份的文件寫在服務器的類路徑下
public static void main(String[] args) {
BakMysql bk = new BakMysql();
bk.backup();
// bk.load();
}
//backup方法是備份數據庫到服務器地址
public void backup() {
Calendar now = Calendar.getInstance();
String name = now.getTime()+””+(now.getTime().getMonth()+1)+””+now.getTime().getDate();
String filename = name.substring(24)+” “+name.substring(11,13)+””+name.substring(14,16)+””+name.substring(17,19);
try {
String filePath =”e:/project”+filename+”.sql”;
Runtime rt = Runtime.getRuntime();
// 調用 mysql 的 cmd:
Process child = rt.exec(“C:/Program Files/MySQL/MySQL Server 5.0/bin/mysqldump.exe -uroot -p8095longchun project”);// 設置導出編碼為utf8。這裡必須是utf8
//注意這一句，是指運行mysqldump命令，後面跟的是登錄名和登錄的密碼，接着後面的是指備份的數據庫的名字，到此結束，以此生成一個執行的進程，取得此進程的輸出流到我們要備份的文件
// 把進程執行中的控制台輸出信息寫入.sql文件，即生成了備份文件。註：如果不對控制台信息進行讀出，則會導致進程堵塞無法運行
InputStream in = child.getInputStream();// 控制台的輸出信息作為輸入流
InputStreamReader xx = new InputStreamReader(in, “utf-8”);// 設置輸出流編碼為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(filePath);
OutputStreamWriter writer = new OutputStreamWriter(fout, “utf8”);
writer.write(outStr);//寫文件
// 註：這裡如果用緩衝方式寫入文件的話，會導致中文亂碼，用flush()方法則可以避免
writer.flush();
// 別忘記關閉輸入輸出流
in.close();
xx.close();
br.close();
writer.close();
fout.close();
} catch (Exception e) {
e.printStackTrace();
}
}
//數據庫的導入
public void load() {
try {
String fPath = “e:/aa.sql”;
Runtime rt = Runtime.getRuntime();
Process child = rt.exec(“C:/Program Files/MySQL/MySQL Server 5.0/bin/mysqladmin.exe -uroot -p8095longchun create project”);
Process child1 =rt.exec(“C:/Program Files/MySQL/MySQL Server 5.0/bin/mysql.exe -uroot -p8095longchun project”);
OutputStream out = child1.getOutputStream();//控制台的輸入信息作為輸出流
String inStr;
StringBuffer sb = new StringBuffer(“”);
String outStr;
BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(fPath), “utf-8”));
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();
} catch (Exception e) {
e.printStackTrace();
}
}
}
原文來自
怎麼用java實現mysql的複製數據庫里所有的表跟數據
樓主要考慮的不僅僅是標題的需求。
1、複製數據庫里所有的表和數據的目的是什麼。
a、假設樓主是要做數據庫備份的話，且通過程序來做的話，可以使用程序來執行dos命令
如java：Runtime.getRuntime().exec(“e:\\MySQL\\bin\\mysqldump -h localhost -uroot -p123 db_name”)
b、假設樓主是要做庫與庫之間的同步的話，可以使用第三方客戶端進行，比如navicat，sqlyong等
c、假設樓主是要做庫與庫之間的同步且用程序進行的話，可以使用mysql中提供操作數據庫的api來做相對應的讀取工作和對比工作，然後寫入工作
原創文章，作者：HRUV，如若轉載，請註明出處：https://www.506064.com/zh-hant/n/141964.html
微信掃一掃 
支付寶掃一掃 