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

更新时间：2013年12月17日 16:31:50 作者：

这篇文章主要介绍了java从mysql导出数据的具体实例，有需要的朋友可以参考一下

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

您可能感兴趣的文章:

Java一些常见的出错异常处理方法总结
下面小编就为大家带来一篇Java一些常见的出错异常处理方法总结。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2016-06-06
浅谈springboot自动装配原理
作为Spring Boot的精髓,自动配置原理首当其冲.今天就带大家了解一下springboot自动装配的原理,文中有非常详细的代码示例,对正在学习java的小伙伴们很有帮助,需要的朋友可以参考下
2021-05-05
mybatis插入与批量插入返回ID的原理详解
这篇文章主要给大家介绍了关于mybatis插入与批量插入返回ID的原理的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用mybatis具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
2019-07-07
大模型chat/completions和completions区别解析
OpenAI的completions和chat/completions是两个不同的端点,completions用于单次文本补全,而chat/completions用于多轮对话生成,选择哪个端点取决于你的具体需求,本文介绍大模型chat/completions和completions区别,感兴趣的朋友一起看看吧
2025-03-03
java并发无锁多线程单线程示例详解
这篇文章主要为大家介绍了java并发无锁多线程单线程示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-07-07
Java对象的XML序列化与反序列化实例解析
这篇文章主要介绍了Java对象的XML序列化与反序列化实例解析，小编觉得还是挺不错的，这里分享给大家。
2017-10-10
如何在springboot中引入参数校验
一般我们判断前端传过来的参数,需要对某些值进行判断,是否满足条件,而springboot相关的参数校验注解,可以解决我们这个问题,本文给大家介绍如何在springboot中引入参数校验,感兴趣的朋友一起看看吧
2023-12-12
SpringBoot+MyBatis实现MD5加密数据库用户密码的方法
MD5技术主要用于对用户密码加密,增加账户的安全性,他具有不可逆的特性,不会被轻易解密,这篇文章给大家介绍SpringBoot+MyBatis实现MD5加密数据库用户密码的方法,感兴趣的朋友跟随小编一起看看吧
2024-03-03
深入理解Java注解类型(@Annotation)
这篇文章主要介绍了深入理解Java注解类型(@Annotation)，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-05-05
使用Java进行图像处理的一些基础操作
这篇文章主要介绍了使用Java进行图像处理的一些基础操作,就载入和输出相关的知识进行了讲解,需要的朋友可以参考下
2015-10-10

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

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具