本文目錄一覽：
- 1、如何用java創建mysql數據庫
- 2、如何用java 5分鐘實現一個最簡單的mysql代理服務器
- 3、怎麼用java實現mysql數據庫的導入導出
- 4、如何用java實現mysql數據庫的導入導出
- 5、怎麼用java實現mysql的複製數據庫里所有的表跟數據
如何用java創建mysql數據庫
JDBC連接數據庫
•創建一個以JDBC連接數據庫的程序，包含7個步驟：
1、加載JDBC驅動程序：
在連接數據庫之前，首先要加載想要連接的數據庫的驅動到JVM（Java虛擬機），
這通過java.lang.Class類的靜態方法forName(String className)實現。
例如：
try{
//加載MySql的驅動類
Class.forName(“com.mysql.jdbc.Driver”) ;
}catch(ClassNotFoundException e){
System.out.println(“找不到驅動程序類 ，加載驅動失敗！”);
e.printStackTrace() ;
}
成功加載後，會將Driver類的實例註冊到DriverManager類中。
2、提供JDBC連接的URL
•連接URL定義了連接數據庫時的協議、子協議、數據源標識。
•書寫形式：協議：子協議：數據源標識
協議：在JDBC中總是以jdbc開始
子協議：是橋連接的驅動程序或是數據庫管理系統名稱。
數據源標識：標記找到數據庫來源的地址與連接端口。
例如：（MySql的連接URL）
jdbc:mysql:
//localhost:3306/test?useUnicode=truecharacterEncoding=gbk ;
useUnicode=true：表示使用Unicode字符集。如果characterEncoding設置為
gb2312或GBK，本參數必須設置為true 。characterEncoding=gbk：字符編碼方式。
3、創建數據庫的連接
•要連接數據庫，需要向java.sql.DriverManager請求並獲得Connection對象，
該對象就代表一個數據庫的連接。
•使用DriverManager的getConnectin(String url , String username ,
String password )方法傳入指定的欲連接的數據庫的路徑、數據庫的用戶名和
密碼來獲得。
例如：
//連接MySql數據庫，用戶名和密碼都是root
String url = “jdbc:mysql://localhost:3306/test” ;
String username = “root” ;
String password = “root” ;
try{
Connection con =
DriverManager.getConnection(url , username , password ) ;
}catch(SQLException se){
System.out.println(“數據庫連接失敗！”);
se.printStackTrace() ;
}
4、創建一個Statement
•要執行SQL語句，必須獲得java.sql.Statement實例，Statement實例分為以下3
種類型：
1、執行靜態SQL語句。通常通過Statement實例實現。
2、執行動態SQL語句。通常通過PreparedStatement實例實現。
3、執行數據庫存儲過程。通常通過CallableStatement實例實現。
具體的實現方式：
Statement stmt = con.createStatement() ;
PreparedStatement pstmt = con.prepareStatement(sql) ;
CallableStatement cstmt =
con.prepareCall(“{CALL demoSp(? , ?)}”) ;
如何用java 5分鐘實現一個最簡單的mysql代理服務器
如何用java 5分鐘實現一個最簡單的mysql代理服務器
首先，準備開發工具套件，我們並不會引入過多工具包，僅僅需要：
java8
vert.x 3
如果你是用maven做為項目管理工具，請將vert.x 3引入：
1
2
3
4
5
dependency
groupIdio.vertx/groupId
artifactIdvertx-core/artifactId
version3.3.2/version
/dependency
代碼實現：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
package
com.maxleap.mysqlproxy;
import
io.vertx.core.AbstractVerticle;
import
io.vertx.core.Vertx;
import
io.vertx.core.logging.Logger;
import
io.vertx.core.logging.LoggerFactory;
import
io.vertx.core.net.NetClient;
import
io.vertx.core.net.NetServer;
import
io.vertx.core.net.NetSocket;
/**
*
@author sneaky
*
@since 1.0.0
*/
public
class
MysqlProxyServer
{
private
static
final
Logger
logger
=
LoggerFactory.getLogger(MysqlProxyServer.class);
public
static
void
main(String[]
args)
{
Vertx.vertx().deployVerticle(new
MysqlProxyServerVerticle());
}
public
static
class
MysqlProxyServerVerticle
extends
AbstractVerticle
{
private
final
int
port
=
3306;
private
final
String
mysqlHost
=
“10.10.0.6”;
@Override
public
void
start()
throws
Exception
{
NetServer
netServer
=
vertx.createNetServer();//創建代理服務器
NetClient
netClient
=
vertx.createNetClient();//創建連接mysql客戶端
netServer.connectHandler(socket
–
netClient.connect(port,
mysqlHost,
result
–
{
//響應來自客戶端的連接請求，成功之後，在建立一個與目標mysql服務器的連接
if
(result.succeeded())
{
//與目標mysql服務器成功連接連接之後，創造一個MysqlProxyConnection對象,並執行代理方法
new
MysqlProxyConnection(socket,
result.result()).proxy();
怎麼用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數據庫的導入導出
MySql導出數據庫的命令如下：
Sql代碼
mysqldump -uusername -ppassword -hhost -Pport exportDatabaseName exportPath
mysqldump -uusername -ppassword -hhost -Pport exportDatabaseName exportPath
利用Java調用命令窗口執行命令來進行MySql導入數據庫一般分三步走：
第一步：登錄Mysql數據庫，在登錄數據庫的時候也可以指定登錄到哪個數據庫，如果指定了則可以跳過第二步；
第二步：切換數據庫到需要導入的目標數據庫
第三步：利用命令開始導入
在進行導出的時候，需要注意命令語句的運行環境，如果已經將mysql安裝路徑下的bin加入到
系統的path變量中，那麼在導出的時候可以直接使用命令語句，否則，就需要在執行命令語句的
時候加上命令所在位置的路徑，即mysql安裝路徑想的bin下的mysqldump命令。
怎麼用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來做相對應的讀取工作和對比工作，然後寫入工作
原創文章，作者：小藍，如若轉載，請註明出處：https://www.506064.com/zh-hant/n/297401.html
微信掃一掃 
支付寶掃一掃 