jdbc讀取mysql大數據

A. java中怎麼獲取mysql資料庫的數據

用JDBC連接資料庫，然後用sql語句。要導入的驅動包。
import java.sql.*;

public class TestMySql {
static Connection con = null; // 聲明Connection對象
static Statement sql = null;
static ResultSet res = null;

public static void main(String[] args) {
TestMySql c = new TestMySql();
con = c.getConnection();
try {
sql = con.createStatement();
res = sql.executeQuery("select * from dept");
//sql語句，我資料庫里有張dept表

while (res.next()) {//輸出結果
System.out.print(res.getString(1) + "<——>");
System.out.print(res.getString(2) + "<——>");
System.out.print(res.getString(3) );
System.out.println();
}

} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (res != null) {
res.close();
res =null;
}
if (sql != null) {
sql.close();
sql =null;
}
if (con != null) {
con.close();
con =null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}

}

public Connection getConnection() {
try {
Class.forName("com.mysql.jdbc.Driver");
// 載入oracleJDBC驅動
System.out.println("資料庫驅動載入成功");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
try {// 通過訪問資料庫的URL獲取資料庫連接對象
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mydata", "root", "qwer1234");
//mydata為mysql名字

System.out.println("資料庫連接成功");
} catch (SQLException e) {
e.printStackTrace();
}
return con; // 按方法要求返回一個Connection對象
}

}

B. 如何將大數據嫻MySql 資料庫

1. 什麼是大數據

1. 所謂大數據, 就是大的位元組數據,或大的字元數據.

2. 標准 SQL 中提供了如下類型來保存大數據類型:

• 位元組數據類型: tinyblob(256B), blob(64K), mediumblob(16M), longblob(4G)

• 字元數據類型: tinyclob(256B), clob(64K), mediumclob(16M), longclob(4G)

3. MySql 中處理字元的數據類型名稱與 SQL 標准不同:

• 字元數據類型: tinytext(256B), text(64K), mediumtext(16M), longtext(4G)

• // 示例: 把 mp3 保存到資料庫中// 需要在 MySql 配置文件中添加如下配置: `max_allowed_packet=10485760`// 因為 MySql 默認不允許數據包傳輸過大



• public class Demo{ // 將 mp3 文件保存到資料庫中


• public void fun1(){ // 獲取連接對象


• Connection con = JdbcUtils.getConnection(); // 提供 sql 模板, 獲取 PreparedStatement 對象


• String sql = "INSERT INTO tab_bin VALUES(?,?,?)";


• PreparedStatement pstmt = con.prepareStatement(sql); // 設置 sql 模板參數


• pstmt.setInt(1,001);


• pstmt.setString(2,"hello.mp3"); // mp3 保存為 blob 類型的數據


• // 通過 commons-io 工具類, 將 mp3 轉換成 byte[]


• Byte[] bytes = IOUtils.toByteArray(new FileInputStream("/Users/姓名/Desktop/hello.mp3")); // 使用 bytes, 創建 Blob 對象


• Blob blob = new SerialBlob(bytes);


• pstmt.setBlob(3,blob); // 發送 sql 語句


• pstmt.executeUpdate();


• } // 從資料庫中獲取 mp3 數據


• public void fun2(){ // 獲取連接對象


• Connection con = JdbcUtils.getConnection(); // 獲取 PreparedStatement 對象


• String sql = "SELECT * FROM tab_bin";


• PreparedStatement pstmt = con.prepareStatement(sql); // 發送 sql 語句, 返回 ResultSet 對象


• ResultSet rs = pstmt.executeQuery(); // 將 rs 中名為 data 列的數據


• if(rs.next()){


• Blob blob = rs.getBlob("data"); // 把 blob 轉換成硬碟上的 mp3 文件



• // 1. 通過 blob 得到輸入流對象


• // 2. 自己創建輸出流對象


• // 3. 把輸入流的數據寫入到輸出流中


• InputStream in = blob.getBinaryStream();


• OutputStream out = new FileOutputStream("/Users/姓名/Document/world.mp3"); // 使用工具類中的方法


• IOUtils.(in,out);


• }


• }


• }

C. 使用JDBC連接mysql資料庫,讀取表test中的數據,並列印

要使用mysql的jar包，資料庫名為test，表名，列名shopName
package com.yunix;

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

public class Test {

public static void main(String []args){
Connection con = getAccessCon();
try {
Statement st = con.createStatement();
ResultSet rs = st.executeQuery("select * from shop");
while(rs.next()){
System.out.println(rs.getString("shopName"));
}
rs.close();
st.close();
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}

public static Connection getAccessCon(){
Connection con = null;
try{
Class.forName("com.mysql.jdbc.Driver").newInstance();
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/test?user=root&password=root");
}catch(Exception e){
e.printStackTrace();
}
return con;
}
}

D. 使用jdbc 下載 mysql的blob欄位中存儲的大文件總是不能下載成功！請問怎麼優化

其實比較好奇的是為什麼要用資料庫存大文件。讀取文件需要讀取到內存中然後進行操作，回如果過大 可能答出現 未讀到頭就沒有內存了的情況。其次還有可能有響應時間的問題。如果超時也有可能出現讀取不成功的情況。
建議按照長度 一次讀取 部分內容 並寫在文件中 最後返回這個文件。也許可以折中處理

E. 通過JDBC訪問資料庫

首先需要導入相應資料庫的驅動文件,然後要注冊驅動,Class.forname(driverName),獲取Connection對象Connection conn=DriverManager.getConnection(URL);然後獲取PreparedStatement對象PreparedStatement pst=conn.getPreparedState(sql,username,password)其中的username和password是你訪問資料庫的名稱和密碼;如果要使用到返回集合則可以用ResultSet對象接收,ResultSet rs=pst.executeQuery();不要使用到返回集合的話就直接pst.executeQuery();
以上的可以查jdk
1.mysql:driverName的值為:com.mysql.jdbc.Driver;url的值為:jdbc:mysql://localhost:3306/hibernate其中hibernate是你的資料庫名稱
2.sqlserver:driverName的值為:com.microsoft.sqlserver.jdbc.SQLServerDriver;url的值為
jdbc:sqlserver://localhost:1433;DatabaseName=" + database,其中database是你資料庫名稱
3.oracle:driverName的值為:oracle.jdbc.driver.OracleDriver;url的值:jdbc:oracle:thin:@127.0.0.1:1521:ora92,其中ora92是你資料庫名稱

F. 怎樣利用JDBC獲得連接,查詢數據,獲取查詢的數據

Java中有個元數據，交MetaData，這個是記錄資料庫和表本身信息的信息，
ResultSet rs=st.executeQuery("select * from student2");
//獲取結果集元數據
ResultSetMetaData rsmd=rs.getMetaData();
//總列數
int size=rsmd.getColumnCount();
//列印列名
for(int i=1;i<=size;i++)
{System.out.print(rsmd.getColumnName(i)+"\t");
}
System.out.println();
//列印列在資料庫中的類型
for(int i=1;i<=size;i++)
{
System.out.print(rsmd.getColumnTypeName(i)+"\t");
}
System.out.println();
//列印列的類型大小
for(int i=1;i<=size;i++)
{
System.out.print(rsmd.getColumnDisplaySize(i)+"\t");
}
System.out.println();
//別名
for(int i=1;i<=size;i++)
{
System.out.print(rsmd.getColumnLabel(i)+"\t");
}
System.out.println();
//列印結果集中數據
while(rs.next())
{
for(int i=1;i<=size;i++)
{
System.out.print(rs.getString(i)+"\t");
}
System.out.println();
}
希望對你有用

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

參考代碼：
package 資料庫編程;
import java.sql.*;
public class 資料庫連接 {
public static void main(String[] args) throws SQLException{
//1.載入驅動程序
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//2.創建與DB資料庫的連接
//連接字元串
String url="jdbc:mysql://192.168.1.101:3306/java資料庫?user=root&password=humin";
Connection con=DriverManager.getConnection(url);
//進行讀寫
if(!con.isClosed()){
System.out.print("歡迎訪問資料庫！\n想做什麼啊………………\n");
Statement st=con.createStatement();
ResultSet rs= st.executeQuery("select * from stu");
while(rs.next()){
System.out.print( rs.getString("stuid")+","+rs.getString("name")+","+rs.getString("sex")+","+rs.getString("age")+","+rs.getString("address")+","+rs.getString("tel")+"\n");
}
}
//關閉資料庫
con.close();
}

}