`
arne3166
  • 浏览: 131098 次
  • 性别: Icon_minigender_1
  • 来自: 南京
社区版块
存档分类
最新评论

数据库比较工具

阅读更多
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class DBFunction
{
    
    public static Connection getConn(DbInfo dbInfo)
    {
        Connection conn = null;
        try
        {
            if (null == conn)
            {
                Class.forName(dbInfo.getDriver());
                conn = DriverManager.getConnection(dbInfo.getUrl(), dbInfo.getUserName(), dbInfo.getPwd());
            }
        }
        catch (ClassNotFoundException cnfe)
        {
            System.out.println("ClassNotFoundException");
        }
        catch (SQLException sqle)
        {
            System.out.println("conn exception ");
        }
        return conn;
    }
    
    /**
     * <一句话功能简述>执行sql语句并得到结果
     * <功能详细描述>
     * @param sql
     * @return
     * @throws SQLException 
     * @see [类、类#方法、类#成员]
     */
    public static List executeSql(String sql, Connection conn)
        throws SQLException
    {
        
        Statement st = null;
        ResultSet rs = null;
        List result = new ArrayList();
        
        try
        {
            
            sql = sql.toUpperCase();
            st = conn.createStatement();
            rs = st.executeQuery(sql);
            String columName = "";
            String values = "";
            
            // 只取select 和 from中间的字段信息
            String[] columns = sql.substring(7, sql.indexOf(" FROM")).split(",");
            while (rs.next())
            {
                values = "";
                
                for (int i = 0; i < columns.length; i++)
                {
                    columName = columns[i].trim();
                    
                    // 这个字段的值是<long>型要特殊处理
                    if (columName.trim().equalsIgnoreCase("DATA_DEFAULT"))
                    {
                        values = values + Tools.streamToString(rs.getBinaryStream(i + 1));
                    }
                    else
                    {
                        values = values + rs.getString(i + 1);
                    }
                    
                    if (i < columns.length - 1)
                    {
                        values = values + ",";
                    }
                    
                }
                
                result.add(values);
            }
        }
        catch (Exception ex)
        {
            System.out.println("sql:" + sql);
            System.out.println("Excute sql occur exception:" + ex.getMessage());
        }
        finally
        {
            try
            {
                if (null != st)
                {
                    st.close();
                    
                }
                if (null != rs)
                {
                    rs.close();
                }
            }
            catch (Exception ex)
            {
                ex.printStackTrace();
            }
        }
        
        return result;
    }
}

 

分享到:
评论
2 楼 arne3166 2011-03-30  
import java.io.File;
import java.sql.Connection;
import java.util.List;

public class GetDBDatas
{
    
    /** <一句话功能简述>
     * <功能详细描述>
     * @param args
     * @see [类、类#方法、类#成员]
     */
    public static void main(String[] args)
    {
        System.out.println("if you have some advise,please send notes to zKF15950 ");
        System.out.println("you using version now:1.2");
        
        File dbConfigXmlFile = new File("./db-cfg.xml");
        
        // 如果文件不存在,退出
        if (!dbConfigXmlFile.exists())
        {
            System.out.println("db-cfg.xml file not exist , program will exit!!");
        }
        
        List dbConfList = ParseXml.parseXml(dbConfigXmlFile);
        
        int num = 0;
        
        // 循环处理每个连接
        for (int i = 0; i < dbConfList.size(); i++)
        {
            DbInfo dbInfo = new DbInfo((String[])dbConfList.get(i));
            
            String path = System.getProperty("user.dir")+"/data"+(++num)+"/";
            
            // 数据库配置有效使用
            if (dbInfo.isUse())
            {
                System.out.println("***********************************************************************");
                System.out.println("Prepare connect to:"+dbInfo.toString());
                
                Connection conn = DBFunction.getConn(dbInfo);
                
                if(null == conn)
                {
                    System.out.println("Db Connect fail!");
                    continue;
                }
                
                File filePath  = new File(path);
                if( ! filePath.exists())
                {
                    filePath.mkdirs();
                }
                else
                {
                    File[] files = filePath.listFiles();
                    for(int j=0;j<files.length;j++)
                    {
                        files[j].delete();
                    }
                }
                
                // 解析库对象
                 ReaderSqls.parseStructure(path,conn);
                 
                 // 获取表数据
                 ReaderSqls.getDatas(path,conn);
            }
        }
        

    }
    
}

1 楼 arne3166 2011-03-30  
/**
 * 
 * 数据库对象信息
 * 包含驱动、URL、UserName、PWD、isUse是否使用
 * 
 * @author  zKF15950
 * @version  [版本号, 2011-3-29]
 * @see  [相关类/方法]
 * @since  [产品/模块版本]
 */
public class DbInfo
{
    private String driver;
    
    private String url;
    
    private String userName;
    
    private String pwd;
    
    private boolean isUse;
    
    public DbInfo(String[] dbInfos)
    {
        url = dbInfos[0];
        driver = dbInfos[1];
        userName = dbInfos[2];
        pwd = dbInfos[3];
        isUse = dbInfos[4].equalsIgnoreCase("yes");
    }
    
    public String getDriver()
    {
        return driver;
    }
    
    public void setDriver(String driver)
    {
        this.driver = driver;
    }
    
    public String getUrl()
    {
        return url;
    }
    
    public void setUrl(String url)
    {
        this.url = url;
    }
    
    public String getUserName()
    {
        return userName;
    }
    
    public void setUserName(String userName)
    {
        this.userName = userName;
    }
    
    public String getPwd()
    {
        return pwd;
    }
    
    public void setPwd(String pwd)
    {
        this.pwd = pwd;
    }
    
    public boolean isUse()
    {
        return isUse;
    }
    
    public void setUse(boolean isUse)
    {
        this.isUse = isUse;
    }
    
    public String toString()
    {
        StringBuffer sbf = new StringBuffer();
        sbf.append("\r\n{").append("\r\n")
        .append("url:").append(url).append("\r\n")
        .append("driver:").append(driver).append("\r\n")
        .append("userName:").append(userName).append("\r\n")
        .append("password:").append(pwd).append("\r\n")
        .append("isUse:").append(isUse).append("\r\n")
        .append("}\r\n");
        return sbf.toString();
    }
}


相关推荐

    Access mdb数据库比较工具

    Access mdb数据库比较工具是一款专为Microsoft Access数据库设计的实用程序,用于对比两个mdb格式的数据库文件,以便找出数据和结构的差异。在数据库管理和维护过程中,这种工具是至关重要的,尤其是当需要同步不同...

    SQLiteCompareSetup(SQLite数据库比较工具)

    SQlite数据库工具 供比较两个SQLite数据库所用。

    Red Gate数据库比较工具

    其产品之一就是“数据库比较工具”,这款工具在数据库管理和开发领域中备受推崇,因其高效、准确且易用的特点而广受好评。 数据库比较工具是Red Gate的旗舰产品之一,主要功能是对比两个数据库之间的结构差异和数据...

    数据库比较工具,风格风格

    数据库比较工具是IT行业中一种非常实用的软件,主要用于检测和同步不同数据库之间的结构差异和数据差异。这种工具在数据库管理、版本控制、迁移和更新过程中起着关键作用。标题中的"风格风格"可能指的是该数据库比较...

    Access数据库比较工具

    Access数据库比较工具是一种专门用于分析和对比两个Access数据库之间差异的实用软件。在数据库管理中,数据一致性至关重要,而Access数据库比较工具可以帮助管理员快速定位并解决数据不一致的问题,提高工作效率。...

    简单快捷数据库比较工具

    数据库比较工具是IT行业中一种非常实用的软件,主要用于在不同数据库之间进行差异分析,以便于数据迁移、同步或版本控制。"简单快捷数据库比较工具"正如其名,它旨在简化这个过程,提供高效且直观的方式来识别和处理...

    sql 数据库比较工具

    SQL数据库比较工具是一种高效实用的软件,主要用于在不同的SQL Server数据库之间进行差异分析和同步操作。这类工具能够帮助数据库管理员和开发人员确保多个环境(如开发、测试和生产环境)中的数据库保持一致,减少...

    MySQL数据库比较工具

    2. **数据内容比较**:除了结构比较,工具还支持对数据库中的实际数据进行比较,找出记录的增删改情况,这对于数据同步和备份恢复至关重要。 3. **生成SQL脚本**:比较结果通常以SQL脚本的形式保存,这些脚本可以...

    数据库比较工具 mssql

    数据库比较工具 MSSQL 是一款专为 SQL Server 设计的强大软件,用于比较和同步不同数据库之间的结构和数据。在IT行业中,数据库管理是一项至关重要的任务,而数据库比较工具则扮演着优化这一过程的角色。MSSQL ...

    数据库比较工具(非常好)

    数据库比较工具是一款非常实用的软件,专为数据库管理员和开发者设计,主要用于对比SQL Server和Oracle数据库之间的结构差异。这款工具能够有效地帮助用户识别并管理不同数据库间的表、视图、存储过程等对象的异同,...

    微型Sql Server查询分析器、数据库比较工具,SQL语句编写助手

    微型Sql Server查询分析器、数据库比较工具以及SQL语句编写助手是数据库管理员和开发人员日常工作中不可或缺的实用工具。这些工具能够帮助用户更高效、准确地执行SQL查询,进行数据库的对比与同步,并优化SQL语句的...

    数据库对比工具(支持sqlserver ,oracle)

    数据库对比工具是IT行业中一种非常实用的软件,主要用于在不同数据库之间进行结构比较,以便于数据库的维护、升级和同步。本工具特别针对SQL Server和Oracle两大主流数据库系统提供了全面的支持,使得数据库管理员和...

    SQL Delta 数据库比较工具

    SQL Delta 数据库比较工具

    数据库比较工具GodswSQLCompare

    很好用的数据库比较工具,可以比较两个数据库中表,视图,存储过程,函数等不同之处,有注册机

    SqlServer数据库比较工具(Web)

    用ASP.NET写的一个SQLSERVER的数据库比较工具,体验MyMVC框架的强大 源码出处:http://www.cnblogs.com/fish-li/archive/2012/03/04/2379612.html

    SQL数据库对比工具

    "SQL数据库对比工具"是专门设计来帮助用户比较和同步两个SQL Server数据库的实用程序。这个工具可以有效地检测并解决数据库之间的差异,确保数据的一致性和准确性。 1. **SQL Server数据库对比**:这是数据库管理员...

Global site tag (gtag.js) - Google Analytics