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();
}

}