javamysql工具

1. 如何用java實現MySQL資料庫的備份和恢復

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

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

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

[java] view plain
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 + "mysqlmp -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的

2. mySQL在java中的應用

Java連接Mysql詳解
Part I: 驅動/數據源類名, URL語法, Connector/J的屬性配置.假設你應經安裝好了mysql, 和mysql-connector-java-X.X.X-bin.jar
Mysql Connector/J通過com.mysql.jdbc.Driver來實現java.sql.Driver, 同時類名org.gjt.mm.mysql.Driver依舊可用, 以保持向前兼容MM.Mysql.
MySQL的JDBC URL格式如下:
如果沒有明確指定host(主機名), 默認為127.0.0.1, 埠號默認是3306
如果不指定資料庫名, 不會有默認的資料庫, 這樣的話, 你可以調用Connection的setCatalog()方法, 或者在SQL中明確指定所用的資料庫. 這種情況只在為多個資料庫建立工具時有用. 例如建立GUI資料庫管理器.
JDBC應該永遠不使用USE database來指定資料庫, 應該用Connection.setCatalog()方法.
MySQL Connector/J支持fail-over模式, 使用fail-over模式, 必須將connection的autoCommit設置為true.
如果URL的autoReconnect設置為false: Failover會發生在連接初始化時, failback出現在驅動器使第一個主機在此可用時.
如果URL的autoReconnect屬性時true, Failover發生在驅動決定connection失敗時(在每次查詢之前), falls back到第一個主機, 當它決定這個主機在此可用時.
在以上提到的兩種情況中, 無論何時你連接到一個"failed-over"伺服器, 這個連接將會是制度的, 因此, 修改數據的查詢, 將會引發異常.
Configuration properties定義Connctor/J將怎樣連接到MySQL伺服器. 除了特別聲明, 這些屬性可以設置在DataSource或Connection object中.
Configuration properties可以按照下面的方式進行設置:
①使用MysqlDataSource或MysqlConnectionPoolDataSource的set*()方法.
②以java.util.Properties的key/value對的形式傳遞給DriverManager.getConnection() 或Driver.connect()
③作為JDBC URL的參數傳給java.sql.DriverManger.getConnection()
java.sql.Driver.connect()或MySQL實現的javax.sql.DataSource setURL() 方法.
注意: 如果你用來確定JDBC URL的機制是XML-based, 你需要使用XML字元 &來分隔參數.

3. Java中的資料庫開源管理工具都有哪些

開源資料庫MySQLMySQL是一個開放源碼的小型關聯式資料庫管理系統，開發者為瑞典MySQL AB公司。目前MySQL被廣泛地應用在Internet上的中小型網站中。由於其體積小、速度快、總體擁有成本低，尤其是開放源...

開源資料庫MySQL

MySQL是一個開放源碼的小型關聯式資料庫管理系統，開發者為瑞典MySQL AB公司。目前MySQL被廣泛地應用在Internet上的中小型網站中。由於其體積小、速度快、總體擁有成本低，尤其是開放源碼這一特點，許多中小型網站為了降低網站總體擁有成本而選擇了MySQL作為網站資料庫。

4. 怎樣用java連接mysql

package com.hhaip.util;

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class DBUtil{
private DBUtil(){}

static{
try{
Class. forName("com.mysql.jdbc.Driver" );
//注冊驅動，而且只需要注冊一次，可以放到static中，要拿到位元組碼文件，
//一定要先載入這個類，而且java中每個類只會被載入一次
}catch(ClassNotFoundException e){
System.out.println( "驅動載入失敗" );
e.printStackTrace(); //列印堆棧里的錯誤解釋給程序員看
}
}

public static void main(String[] args){}

public static Connection getConn(){
Connection conn = null;//成員變數一定要初始化
try{
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "root" ); //jdbc:mysql:///test"
} catch(SQLException e){
e.printStackTrace();
}
return conn;
}

public static Statement getStmt(Connection conn){
Statement stmt = null;
try{
stmt = conn.createStatement();
} catch(SQLException e){
e.printStackTrace();
}
return stmt;
}

public static PreparedStatement getPstmt(Connection conn,String sql){
PreparedStatement pstmt = null;
try{
pstmt = conn.prepareStatement(sql);
} catch(SQLException e){
e.printStackTrace();
}
return pstmt;
}

public static ResultSet getRs(Statement stmt,String sql){
ResultSet rs = null;
try{
rs = stmt.executeQuery(sql);
} catch(SQLException e){
e.printStackTrace();
}
return rs;
}

public static ResultSet getRs(PreparedStatement pstmt){
ResultSet rs = null;
try{
rs = pstmt.executeQuery();
//excuteQuery有返回結果給rs，為什麼這里沒sql語句，因為pstmt裡面已經執行了一句sql
//stmt中沒有sql語句，所以它還要傳一個sql語句給rs。
} catch(SQLException e){
e.printStackTrace();
}
return rs;
}

public static void close(ResultSet rs){
if(rs!=null ){
try{
rs.close();
rs= null; //讓java的垃圾回收機制把沒用的內存回收，可以將對象的引用置為空
} catch(SQLException e){
e.printStackTrace();
}
}
}

public static void close(Statement stmt){
if(stmt!=null){
try{
stmt.close();
stmt= null; //讓java的垃圾回收機制把沒用的內存回收，可以將對象的引用置為空
} catch(SQLException e){
e.printStackTrace();
}
}
}

public static void close(Connection conn){
if(conn!=null){
try{
conn.close();
conn= null; //讓java的垃圾回收機制把沒用的內存回收，可以將對象的引用置為空
} catch(SQLException e){
e.printStackTrace();
}
}
}

}

1、上面的代碼放在一個類里，類名DBUtil.這個類是連接MySQL的工具類，你要先下好MySQL的資料庫驅動jar包，還有安裝好MySQL。已經上傳到附近了。

2、"jdbc:mysql://localhost:3306/test", "root", "root" 這里test是你MySQL里的資料庫名稱，這里連接了test資料庫，你也可以自己新建自己的資料庫。兩個root分別是資料庫的登陸名和密碼，安裝MySQL的時候設置的，只要在你的DAO里調用我這個工具類就可以了。

5. 如何在Java程序中訪問mysql資料庫中的數據並進行簡單的操作

一、使用工具：java語言、Myeclipse。
二、操作步驟：
1、第一步：載入MySQL的JDBC的驅動

2、第二步：創建與MySQL資料庫的連接類的實例

3、第三步：獲取連接類實例con，用con創建Statement對象類實例 sql_statement

4、第四步：執行查詢，用ResultSet類的對象，返回查詢的結果

5、得出數據

三、注意事項：有幾處是需要根據自身情況修改的
1、如下圖中的url和賬號，密碼需要與你自己的相一致。

2、這些需要訪問的數據必須要與資料庫中的類型相互匹配，才能列印出正確的結果。

6. java開發項目最好用那些工具軟體mysql+tomcat還是access+sql sever

框架：ssh(struts2 spring hibernate) freemarker ajax
伺服器： apache tomcat
工具：eclipse mysql (可以使用Navicat for MySQL來操作mysql簡單方便) PowerDesigner(資料庫設計)
還有可以裝個火狐瀏覽器安裝個firebug插件，頁面調試用很方便。
這些都是常用的供你參考。

7. java在eclipse工具裡面要如何連接mysql的資料庫進行操作啊

應該還有個jar包，你導入沒有？看圖

8. 基於Java的應用MySQL讀寫分離用什麼工具或類庫來實現

利用PerformanceCounter來實現
該類位於System.Diagnostics中
構造函數public PerformanceCounter(string categoryName, string counterName, string instanceName);
參數說明：1、categoryName，計數器類別名
PerformanceCounterCategory[] p = PerformanceCounterCategory.GetCategories();此方法可以獲取所有categoryName，例如CPU就是Processor Information
2、 string counterName 實例名和計數器名instanceName
PerformanceCounterCategory pcc = new PerformanceCounterCategory(CategoryName);
string[] s = pcc.GetInstanceNames();此方法可以獲取類別名為CategoryName的所有實例名；
再根據實例名去取得該實例下計數器的名稱
PerformanceCounter[] pc =pcc.GetCounters(instanceNames[i])
你要的基本上都在裡面了，我就不具體實現了

補充：如果你要再頁面上使用，讀取客戶端機器的信息，需要封裝成ActiveX或者COM

9. 如何用java 5分鍾實現一個最簡單的mysql代理伺服器

如何用java 5分鍾實現一個最簡單的mysql代理伺服器
首先，准備開發工具套件，我們並不會引入過多工具包，僅僅需要：
java8
vert.x 3
如果你是用maven做為項目管理工具，請將vert.x 3引入：

1
2
3
4
5

<dependency>

<groupId>io.vertx</groupId>

<artifactId>vertx-core</artifactId>

<version>3.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();