之前已经使用SchemaSpy工具分析了数据库的结构，之后就可以比较方便的将数据从数据库导出到Excel等文件中，这次我选择使用Python来完成这个工作。


1 任务简介

把PostgreSql数据库中5张表的数据导出到Excel文件中，查询的字段涉及到5张表，所以需要联合查询，其中还有两张表存在自引用，所以还会更复杂一些。

2 工具

使用psycopg2模块连接数据库
使用xlwt模块操作Excel文件
2.1 psycopg2

这个模块用法很常规，

连接数据库
执行SQL
获取结果
重点在于SQL语句的构造，因为涉及多个表，所以不得已要使用join，那么为了考虑效率应当把数据量大的表放在小表的前面。

2.2 xlwt

这个模块用于写Excel文件，与之对应的还有xlrd来完成读文件的操作。 

用法也很简单，

新建Excel文件
新建sheet表 
定位起始单元格 
写内容 
保存&关闭文件 
需要注意的问题有两点:

文件编码，新建文件时需要指明utf-8 
表格大小，由于xls文件最多只能到65535行，所以表过大的时候要么换xlsx格式，要么切分成多个表。Python处理xlsx的模块是xlsxwriter
3 代码

具体实现如下：

#!/usr/bin/env python  
# -*- coding: utf-8 -*-  

import psycopg2
import xlwt

hostIp = '127.0.0.1'
port = '5432'
dbName = 'source'
user = 'liuyueyi'
password = 'password'


sql = '''
select site.name,study.name,sheets.id,sheets.patient_name,crf.label,section.label,form_rows.uid,form_rows.label,sheet_row_values.value 
from sheet_row_values 
inner join form_rows on form_rows.uid = sheet_row_values.uid 
inner join form_groups section on section.id = form_rows.group_id
inner join form_groups crf on section.parent_id = crf.id
inner join sheets on sheets.id = sheet_row_values.sheet_id 
inner join departments site on sheets.center_id = site.id 
inner join departments study on site.parent_id = study.id;
'''

file = xlwt.Workbook(encoding='utf-8')

sheet1 = file.add_sheet(u'sheet1')

row0 = [u'site_name',u'study_name',u'sheets_id',u'patient_name',u'crf_name',u'section_name',u'form_rows_uid',u'form_rows_label',u'row_value']
for i in range(0, len(row0)):
  sheet1.write(0,i,row0[i])


conn = psycopg2.connect(database=dbName,host=hostIp,port=port,user=user,password=password)
cur = conn.cursor()
cur.execute(sql)
rows = cur.fetchall()

for i in range(0,len(rows)):
  for j in range(0,len(rows[i])):
    sheet1.write(i+1,j,rows[i][j])

file.save('result.xls')


java把数据从数据库导入到excel
 
 
package com.madhouse.sys.util;
 
import java.io.File;
import java.io.IOException;
 
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
 
import jxl.Workbook;
import jxl.write.Label;
import jxl.write.WritableSheet;
import jxl.write.WritableWorkbook;
import jxl.write.WriteException;
import jxl.write.biff.RowsExceededException;
 
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
 
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
 
/**
 * <li>把数据导入到Excel公用类</li>
 * </br> This is about <code>ExcelUtil</code>
 * 
 * @author hjy273
 * @version 1.0
 * @date Sep 6, 2008 9:52:52 PM
 */
public class ExcelUtil {
 
    private static Log log = LogFactory.getLog(ExcelUtil.class);
 
    public ExcelUtil() {
 
    }
 
    public boolean DB2Excel(ResultSet rs) {
        boolean flag = false;
        WritableWorkbook workbook = null;
        WritableSheet sheet = null;
        Label label = null;
 
        // 创建Excel表
        try {
             workbook = Workbook.createWorkbook(new File("e:/_report/output.csv"));
            //workbook = Workbook.createWorkbook(os);
             
             // 创建Excel表中的sheet
            sheet = workbook.createSheet("First Sheet", 0);
 
            // 向Excel中添加数据
            ResultSetMetaData rsmd = rs.getMetaData();
            int columnCount = rsmd.getColumnCount();
            String colName = null;
            int row = 0;
            // 添加标题
            for (int i = 0; i < columnCount; i++) {
                colName = rsmd.getColumnName(i + 1);
                label = new Label(i, row, colName);
                // log.debug("标题:"+i+"---"+row +"---"+ colName);
                sheet.addCell(label);
            }
            row++;
            log.debug("写入标题成功");
            while (rs.next()) {
                for (int i = 0; i < columnCount; i++) {
                    label = new Label(i, row, rs.getString(i + 1));
                    log.debug("行:"+i+"---"+row +"---"+ rs.getString(i+1));
                    sheet.addCell(label);
                }
                row++;
            }
            log.debug("写入内容成功");
 
            // 关闭文件
            workbook.write();
            workbook.close();
            log.info("数据成功写入Excel");
            flag = true;
        } catch (SQLException e) {
            log.debug(e.getMessage());
        } catch (RowsExceededException e) {
            log.debug(e.getMessage());
        } catch (WriteException e) {
            log.debug(e.getMessage());
        } catch (IOException e) {
            log.debug(e.getMessage());
        } finally {
            try {
                workbook.close();
            } catch (Exception e) {
            }
        }
        return flag;
    }
 
    /**
     * 测试方法
     * 
     * @param args
     */
    public static void main(String[] args) {
        // write your code
        try {
 
            Class.forName("org.gjt.mm.mysql.Driver").newInstance();
            Connection conn = (Connection) DriverManager
                    .getConnection(
                            "jdbc:mysql://localhost:3306/firewall?useUnicode=true&characterEncoding=utf8",
                            "root", "root");
            Statement st = (Statement) conn.createStatement();
            ResultSet rs = st
                    .executeQuery("select * from firewall.tb_operator");
             if (!new ExcelUtil().DB2Excel(rs)){
                 log.info("数据写入失败");
             }
            rs.close();
            st.close();
            conn.close();
 
        } catch (Exception e) {
            e.printStackTrace();
        }
 
    }
 
}

如何使用php实现将数据从excel表导入到mysql中？
把excel 改为 cvs文件
//连数据件
$connect=mysql_connect("localhost","admin","admin") or die("链接数据库！");
//连接数据库(test)
mysql_select_db("testcg",$connect) or die (mysql_error());
$temp=file("test.csv");//连接EXCEL文件,格式为了.csv
for ($i=0;$i 
{
$string=explode(",",$temp[$i]);//通过循环得EXCEL文件中每行记录的值
//将EXCEL文件中每行记录的值插入到数据库中
$q="insert into ceshi (name,num,dom) values('$string[0]','$string[1]','$string[2]');";
mysql_query($q) or die (mysql_error());
if (!mysql_error());
{
echo " 成功导入数据!";
}
echo $string[4]."\n";
unset($string);
}
?>
原生PHP代码实现excel导入,并添加数据到数据库.
把excel 改为 cvs文件
//连数据件
$connect=mysql_connect("localhost","admin","admin") or die("链接数据库！");
//连接数据库(test)
mysql_select_db("testcg",$connect) or die (mysql_error());
$temp=file("test.csv");//连接EXCEL文件,格式为了.csv
for ($i=0;$i 
{
$string=explode(",",$temp[$i]);//通过循环得EXCEL文件中每行记录的值
//将EXCEL文件中每行记录的值插入到数据库中
$q="insert into ceshi (name,num,dom) values('$string[0]','$string[1]','$string[2]');";
mysql_query($q) or die (mysql_error());
if (!mysql_error());
{
echo " 成功导入数据!";
}
echo $string[4]."\n";
unset($string);
}
?>
导入excel文件，后端php处理导入的数据并存入数据...
我用的代码是：
//连文件
$connect=mysql_connect("localhost","admin","admin") or die("链接数据库失败！");
//连接数据库(test)
mysql_select_db("testcg",$connect) or die (mysql_error());
$temp=file("test.csv");//连接EXCEL文件,格式为了.csv
for ($i=0;$i 
{
$string=explode(",",$temp[$i]);//通过循环EXCEL文件中每行记录的值
//将EXCEL文件中每行记录的值插入到数据库中
$q="insert into ceshi (name,num,dom) values('$string[0]','$string[1]','$string[2]');";
mysql_query($q) or die (mysql_error());
if (!mysql_error());
{
echo " 成功导入数据!";
}
echo $string[4]."\n";
unset($string);
}
?>
--------------------------------------------------------------------------------
phpexcel或者pear的一个组件 ，国内有一个excelclass的插件
都是用来处理excel的，前2个功能都比较强大，对编码的支持也都不错，推荐使用pear的那个，名字好像叫spreadsheet reader
phpexcel比较费资源，不过并不是所有的excel都能读取
楼主可以到这里去看看 pear.php.net
--------------------------------------------------------------------------------
顶楼上的回答~~顺便接个分!嘿嘿
--------------------------------------------------------------------------------
AdO直接上传
注意有些字符mysql或ADO可能不支持
--------------------------------------------------------------------------------
首先确认你的数据库是什么编码的，以utf-8为例，
你首先打开excel 文件，然后保存，选择为另存为.csv文件。
然后用文本编辑器打开.csv文件，另存为utf-8的csv
然后你写php 可以使用php 的getcsv  打开(这样确保你有的字段中含有,而导致解析错误)，然后把解析的结果导入到数据库中。
然后完了。
PHPExcel如何从excel表导入到mysql数据库
'写入库.
oconn.execute(insert
into
users(userid,password)values('

[1].[代码]



view
 source


print?







001

java把数据从数据库导入到excel









002

 









003

 









004

package com.madhouse.sys.util;









005

 









006

import java.io.File;









007

import java.io.IOException;









008

 









009

import java.sql.DriverManager;









010

import java.sql.ResultSet;









011

import java.sql.ResultSetMetaData;









012

import java.sql.SQLException;









013

 









014

import jxl.Workbook;









015

import jxl.write.Label;









016

import jxl.write.WritableSheet;









017

import jxl.write.WritableWorkbook;









018

import jxl.write.WriteException;









019

import jxl.write.biff.RowsExceededException;









020

 









021

import org.apache.commons.logging.Log;









022

import org.apache.commons.logging.LogFactory;









023

 









024

import com.mysql.jdbc.Connection;









025

import com.mysql.jdbc.Statement;









026

 









027

/**









028

 *
 <li>把数据导入到Excel公用类</li>









029

 *
 </br> This is about <code>ExcelUtil</code>









030

 *









031

 *
 @author hjy273









032

 *
 @version 1.0









033

 *
 @date Sep 6, 2008 9:52:52 PM









034

 */









035

public class ExcelUtil
 {









036

 









037

    private static Log
 log = LogFactory.getLog(ExcelUtil.class);









038

 









039

    public ExcelUtil()
 {









040

 









041

    }









042

 









043

    public boolean DB2Excel(ResultSet
 rs) {









044

        boolean flag
 = false;









045

        WritableWorkbook
 workbook = null;









046

        WritableSheet
 sheet = null;









047

        Label
 label = null;









048

 









049

        //
 创建Excel表









050

        try {









051

             workbook
 = Workbook.createWorkbook(new File("e:/_report/output.csv"));









052

            //workbook
 = Workbook.createWorkbook(os);









053

             









054

             //
 创建Excel表中的sheet









055

            sheet
 = workbook.createSheet("First
 Sheet", 0);









056

 









057

            //
 向Excel中添加数据









058

            ResultSetMetaData
 rsmd = rs.getMetaData();









059

            int columnCount
 = rsmd.getColumnCount();









060

            String
 colName = null;









061

            int row
 = 0;









062

            //
 添加标题









063

            for (int i
 = 0;
 i < columnCount; i++) {









064

                colName
 = rsmd.getColumnName(i + 1);









065

                label
 = new Label(i,
 row, colName);









066

                //
 log.debug("标题:"+i+"---"+row +"---"+ colName);









067

                sheet.addCell(label);









068

            }









069

            row++;









070

            log.debug("写入标题成功");









071

            while (rs.next())
 {









072

                for (int i
 = 0;
 i < columnCount; i++) {









073

                    label
 = new Label(i,
 row, rs.getString(i + 1));









074

                    log.debug("行:"+i+"---"+row
 +"---"+
 rs.getString(i+1));









075

                    sheet.addCell(label);









076

                }









077

                row++;









078

            }









079

            log.debug("写入内容成功");









080

 









081

            //
 关闭文件









082

            workbook.write();









083

            workbook.close();









084

            log.info("数据成功写入Excel");









085

            flag
 = true;









086

        } catch (SQLException
 e) {









087

            log.debug(e.getMessage());









088

        } catch (RowsExceededException
 e) {









089

            log.debug(e.getMessage());









090

        } catch (WriteException
 e) {









091

            log.debug(e.getMessage());









092

        } catch (IOException
 e) {









093

            log.debug(e.getMessage());









094

        } finally {









095

            try {









096

                workbook.close();









097

            } catch (Exception
 e) {









098

            }









099

        }









100

        return flag;









101

    }









102

 









103

    /**









104

     *
 测试方法









105

     *









106

     *
 @param args









107

     */









108

    public static void main(String[]
 args) {









109

        //
 write your code









110

        try {









111

 









112

            Class.forName("org.gjt.mm.mysql.Driver").newInstance();









113

            Connection
 conn = (Connection) DriverManager









114

                    .getConnection(









115

                            "jdbc:mysql://localhost:3306/firewall?useUnicode=true&characterEncoding=utf8",









116

                            "root", "root");









117

            Statement
 st = (Statement) conn.createStatement();









118

            ResultSet
 rs = st









119

                    .executeQuery("select
 * from firewall.tb_operator");









120

             if (!new ExcelUtil().DB2Excel(rs)){









121

                 log.info("数据写入失败");









122

             }









123

            rs.close();









124

            st.close();









125

            conn.close();









126

 









127

        } catch (Exception
 e) {









128

            e.printStackTrace();









129

        }









130

 









131

    }









132

 









133

}