java从mysql导出数据的具体实例

#技术教程发布时间： 2026-01-17

复制代码代码如下:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestDB {

public static void main(String[] args) {

//Test(); // 生成测试数据
//Exp();
Exp(0);
//System.out.println(readText("/opt/id.txt"));
}

/**
* 导出数据
*/
public static void Exp() {

Connection Conn=null;

   try {


    Class.forName("com.mysql.jdbc.Driver").newInstance();
    String jdbcUrl = "jdbc:mysql://127.0.0.1:3306/test?characterEncoding=GBK";
    //String jdbcUsername = "root";
    //String jdbcPassword = "mysql";
    Conn = DriverManager.getConnection(jdbcUrl, "root", "mysql");

    System.out.println("conn"+Conn);

    Exp(Conn);

   try {

    Class.forName("com.mysql.jdbc.Driver").newInstance();
    String jdbcUrl = "jdbc:mysql://127.0.0.1:3306/test?characterEncoding=GBK";
    String jdbcUsername = "root";
    String jdbcPassword = "mysql";
    Conn = DriverManager.getConnection(jdbcUrl, jdbcUsername, jdbcPassword);

    System.out.println("conn"+Conn);

    Exp(Conn,startid);

   } catch (SQLException e) {
    e.printStackTrace();
   }
   catch (InstantiationException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   } catch (IllegalAccessException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   } catch (ClassNotFoundException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   finally
   {

    try {
     Conn.close();
    } catch (SQLException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }

}

/**
   * 导出从startid开始的数据
   * @param conn
   * @param start_id
   */
public static void Exp(Connection conn,int start_id) {

   int counter = 0;
   int startid=start_id;
   boolean flag = true;
   while (flag) {
    flag = false;
    String Sql = "SELECT * FROM t_test WHERE id>"
      + startid + " order by id asc LIMIT 50";

    System.out.println("sql===" + Sql);
    try {
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery(Sql);

      while (rs.next()) {
       flag = true;
       int id = rs.getInt("id");
       String title = rs.getString("title");
       startid = id ;

       counter++;

       writeContent(counter+"--id--"+id+"--title-"+title+"\r\n", "D:\\","log.txt",true);

       System.out.println("i="+counter+"--id--"+id+"--title-"+title);

      }
     rs.close();
     stmt.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   }

   writeContent(""+startid, "D:\\","id.txt",false);

}

/**
   * 导出一小时内的数据
   * @param conn
   */

public static void Exp(Connection conn) {

   int counter = 0;
   //一小时内的数据
   Long timestamp = System.currentTimeMillis() - (600 * 60 * 1000);
   boolean flag = true;
   while (flag) {
    flag = false;
    String Sql = "SELECT * FROM t_test WHERE createTime>"
      + timestamp + " LIMIT 50";

    System.out.println("sql===" + Sql);
    try {
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery(Sql);
     while (rs.next()) {
      flag = true;
      int id = rs.getInt("id");
      String title = rs.getString("title");
      Long lastmodifytime = rs.getLong("createTime");
      timestamp = lastmodifytime;

      counter++;

      System.out.println("i="+counter+"--id--"+id+"--title-"+title);

     }
     rs.close();
     stmt.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   }

}

public static void Test() {

Connection Conn=null;

public static void add(Connection conn,String title)
   {
      PreparedStatement pstmt = null;
   String insert_sql = "insert into t_test(title,createTime) values (?,?)";

   System.out.println("sql="+insert_sql);
   try {
    pstmt = conn.prepareStatement(insert_sql);
    pstmt.setString(1,title);
    pstmt.setLong(2,System.currentTimeMillis());
    int ret = pstmt.executeUpdate();

   } catch (SQLException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   finally{
    try {
     pstmt.close();
    } catch (SQLException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }

     }

/**
   * 写入内容到文件
   *
   * @param number
   * @param filename
   * @return
   */
public static boolean writeContent(String c, String dirname,String filename,boolean isAppend) {

   File f=new File(dirname);
   if (!f.exists())
   {
     f.mkdirs();
   }

   try {
    FileOutputStream fos = new FileOutputStream( dirname+File.separator+filename,isAppend);
    OutputStreamWriter writer = new OutputStreamWriter(fos);
    writer.write(c);
    writer.close();
    fos.close();
   } catch (IOException e) {
    e.printStackTrace();
    return false;
   }
   return true;
}

/**
   * 从文件读取内容
   *
   * @param filename
   * @return
   */
public static String readText(String filename) {
   String content = "";
   try {
    File file = new File(filename);
    if (file.exists()) {
     FileReader fr = new FileReader(file);
     BufferedReader br = new BufferedReader(fr);
     String str = "";
     String newline = "";
     while ((str = br.readLine()) != null) {
      content += newline + str;
      newline = "\n";
     }
     br.close();
     fr.close();
    }
   } catch (IOException e) {
    e.printStackTrace();
   }
   return content;
}
}

上一篇 : C#自动给文章关键字加链接实现代码

下一篇 : 优化大型数据集的直接相关性计算：限制滞后范围

首页

关于我们

SEO服务

品牌推广

营销学院

联系我们

java从mysql导出数据的具体实例

SEO公司

SEO套餐

SEO教程

SEO资源

SEO建站

推荐阅读

Ubuntu服务器版操作系统在网站托管方

IIS服务器日志分析：如何通过日志文件诊

ASP.NET应用在VPS环境下的备份与

128内存建站：内容管理系统（CMS）的

128内存建站：如何优化网站性能以提高加

2025年建站过程中常见的安全问题及解决

不同操作系统下（如Linux、Windo

ASP.NET 本地开发中常见的错误及解

128MB内存建站：如何优化服务器性能

618购物狂欢节，企业如何通过网络建站提

128MB内存建站：怎样通过代码精简提升

ASP企业网站自助建站系统免费版提供哪些

个人服务器网站搭建过程中，常见的错误配置

Dreamweaver云建站能否与第三方

2025年最流行的开源内容管理系统(CM

128内存建站：有哪些方法可以减少HTT

中型网站达到多少流量时需要考虑升级服务器

256内存建站：如何应对高流量访问的挑战

ASP企业网站自助建站系统免费版是否支持

为什么正确配置服务器权限对网站安全至关重

Comtop建站系统的域名绑定和解析步骤

618建站攻略：怎样优化网站SEO以吸引

GoDaddy建站过程中常见的技术支持问

ASP.NET Core与传统ASP.N

ASP.NET企业自助建站系统支持哪些数

个人网站服务器：共享主机、VPS与专用服

为什么有些服务器提供商声称“免费试用”，

个人网站服务器配置：应对流量高峰，CDN

IIS 0日志记录功能详解及日志分析工具

2025年建站代理服务：SEO优化在网站

SSL证书对网站服务器安全性和SEO排名

2025年中国建站：移动优化的重要性及实

Java快速建站系统的安装和配置步骤是什

2025年利用社交媒体推广新建立的网站以

2025年最受欢迎的开源电子商务建站平台

DDoS攻击防范：如何利用服务器配置抵御

SSL证书对网站服务器的重要性：提升安全

DDoS攻击下网站服务器无法访问：防御与

ADSL网络建站：域名注册与备案需要注意

128MB内存建站：图片和多媒体文件的优