tinifile.cpp

把oracle库中的数据插入到mysql表中 oracle2mysql

// TIniFile.cpp: implementation of the TIniFile class.
//
//////////////////////////////////////////////////////////////////////

#include "TIniFile.h"

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

TIniFile::TIniFile()
{
}

TIniFile::~TIniFile()
{

}

int TIniFile::Open(ACE_TString filename)
{
	int i = 0;
	char name[16] = {0};
	ACE_Configuration_Heap config; 
	config.open();
	ACE_Ini_ImpExp impExp(config); //windows的.ini格式，注意读出来的都是字符串，类型需要自己转换

	if(impExp.import_config(filename.c_str()) != 0) //读取配置文件 
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : open ini file %s error...\n"),filename.c_str()));
		return -1;
	}

	ACE_Configuration_Section_Key section; //指向一个配置节section

	/*[MYSQL]*/
    if(config.open_section(config.root_section(), ACE_TEXT("MYSQL"), 0, section) != 0)
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : open_section %s error...\n"), ACE_TEXT("MYSQL")));
		return -1;
	}

	if(config.get_string_value(section, ACE_TEXT("host"), host) != 0)
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get host error...\n")));
		return -1;
	}

	if(config.get_string_value(section, ACE_TEXT("port"), tmp) != 0) 
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get port error, use default value...\n")));
		port = 3306;
	}
	else
	{
		port = ACE_OS::atoi(tmp.c_str());
	}

	if(config.get_string_value(section, ACE_TEXT("user"), user) != 0) 
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get user error...\n")));
		return -1;
	}

	if(config.get_string_value(section, ACE_TEXT("pwd"), pwd) != 0) 
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get pwd error...\n")));
		return -1;
	}

	if(config.get_string_value(section, ACE_TEXT("tablename"), tablename) != 0) 
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get tablename error...\n")));
		return -1;
	}

	/*[ORACLE]*/
	if(config.open_section(config.root_section(), ACE_TEXT("ORACLE"), 0, section) != 0)
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : open_section %s error...\n"), ACE_TEXT("ORACLE")));
		return -1;
	}

	if(config.get_string_value(section, ACE_TEXT("dblogin"), dblogin) != 0)
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get dblogin error...\n")));
		return -1;
	}

	if(config.get_string_value(section, ACE_TEXT("sql"), sql) != 0)
	{
		ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("%D : get sql error...\n")));
		return -1;
	}
	
	return 0;
}

void TIniFile::Print()
{
	ACE_TString tmp;

	ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("MYSQL:\n")));
	ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("\thost=%s\n\tport=%d\n\tuser=%s\n\tpwd=%s\n\ttablename=%s\n"), host.c_str(), port, user.c_str(), pwd.c_str(), tablename.c_str()));
	ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("ORACLE:\n")));
	ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("\tdblogin=%s\n\tsql=%s\n"),dblogin.c_str(),sql.c_str()));
}