java程序读取数据库表 转为sql文件 仅供参考 不得宣传

package com.nokia.ices.radio.utils; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStreamWriter; import java.io.Writer; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import java.util.Properties; import com.mysql.jdbc.PreparedStatement; public class OutSql { public void outsql(String tableName,String savePath,Connection conn,String dataBaseName) throws SQLException{ PreparedStatement pst=null; ResultSet rs=null; /* * 获取表的字段 */ String column="select COLUMN_NAME from information_schema.columns where table_name='"+tableName+"' and table_schema = '"+dataBaseName+"';"; List<String> columnList=new ArrayList<String>(); pst=(PreparedStatement) conn.prepareStatement(column); rs=pst.executeQuery(); while(rs.next()){ columnList.add(rs.getString(1)); } rs.last(); int columnNO=rs.getRow();//存贮表字段的个数 //拼接表的所有字段 StringBuffer sql=new StringBuffer(); for(int i=0;i<columnList.size();i++){ sql.append(columnList.get(i)); if(i<columnList.size()-1){ sql.append(","); } } /* * 查询表的数据 */ String selectAll="select "+sql+" from "+tableName; System.out.println("sql语句："+selectAll); //封装表的数据 List<List<Object>> tableList=new ArrayList<List<Object>>(); try { pst=(PreparedStatement) conn.prepareStatement(selectAll); rs=pst.executeQuery(); while(rs.next()){ List<Object> rowList=new ArrayList<Object>(); for(int i=1;i<columnNO+1;i++){ rowList.add(rs.getObject(i)); } tableList.add(rowList); } } catch (SQLException e) { e.printStackTrace(); } /* * 转换成sql输出到指定位置 */ ChangeToString cts=new ChangeToString(); File file = new File(savePath + File.separator + tableName+".sql"); try { Writer writer = new OutputStreamWriter(new FileOutputStream(file, false), "utf-8"); for(List<Object> list:tableList){ String str=cts.changeToStirng(list); String insSql = "insert into "+tableName+" values (" + str + ");"+ "\n\n"; System.out.println(insSql); writer.write(insSql ); } writer.close(); } catch (IOException e) { e.printStackTrace(); } } }