怎么在一个项目中连接两个数据库？

一个项目想同时连接两个数据库。~

用分布式数据同步，mysql提供分布式数据同步功能，spring也很容易配置，详细资料，网上查查，mysql的doc中也提供例子。

相信你这样一系统，肯定用了三层架构的模式，这样的话就好解决了，在数据访问层专一个连接数据库的有参方法。在调用该方法时传递不同数据库名即可，当然，每次在数据库访问层操作后一定要断掉数据连接，对一些实例清空回收，这很重要。
public DatabaseClass(String databaseName )
{
strDbConnection="server=.;uid=sa;pwd=sa;database="+ databaseName;
}
给你一点我以前的代码，或许对你有用。
------------------------------------------------------------------
using System;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
using System.ComponentModel;

namespace Common
{

public class DatabaseClass
{

static String strDbConnection=""; // 保存数据库连接字符串
static bool isCon; // 数据库连接标志
static SqlConnection con; //数据库连接对象
static SqlCommand cmd; //SQL命令对象
private SqlTransaction _sqlTransaction; //事务对象
private bool _isStartTransaction; //事务开启标志

//无参构造
public DatabaseClass()
{
//strDbConnection="server=.;uid=sa;pwd=sa;database=emporiumDB";
strDbConnection="server=.;uid=sa;pwd=sa;database=BankDB";
}

//有参构造(从外部传入连接串)
public DatabaseClass(String ConnectionString)
{
if (ConnectionString != "")
{
strDbConnection = ConnectionString;
con=null;
isCon =false;
}
}

//打开数据库连接,成功返回true
private bool ConnectDb()
{
//若数据库不处于连接状态,则执行连库操作
if (!isCon)
{
try
{
//如果没有连接，就实例化一个新的连接
if (con == null)
{
con = new SqlConnection(strDbConnection);
con.Open();

}

//有SQL命令有无例化对象，没就就实例化一新的。
if (cmd == null)
{
cmd = new SqlCommand();
}
isCon = true;
cmd.Connection = con;
}
catch(Exception e)
{
throw e;
}
}
return true;
}



//执行单向SQL语句，如插入、删除、修改，成功返回true
public bool Execute(string sSql)
{

if (!ConnectDb())
{
throw(new ApplicationException("没有建立数据库连接"));
}

cmd.CommandType = System.Data.CommandType.Text;
cmd.CommandText = sSql;
try
{
cmd.ExecuteNonQuery();
return true;
}
catch(SqlException e)
{
throw new Exception("执行SQL语句时出现问题"+e.Message );

}
catch(Exception e)
{
throw e;

}
finally
{
Dispose();
}

}


//执行返回int型单值的SQL语句
public int ExecuteScalar(string sql)
{
int count=0;

if (!ConnectDb())
{
throw new Exception("没有建立数据库连接");
}

cmd.CommandType = System.Data.CommandType.Text;
cmd.CommandText = sql;
try
{
count=(int)cmd.ExecuteScalar();
return count;
}
catch(SqlException e)
{
throw new Exception("执行SQL语句时出现问题"+e.Message );

}
catch(Exception e)
{
throw e;
}
finally
{
Dispose();
}

}

//执行返回字符串类型单值的SQL语句
public string ExecuteString(string sql)
{
string str="";

if (!ConnectDb())
{
throw new Exception("没有建立数据库连接");
}

cmd.CommandType = System.Data.CommandType.Text;
cmd.CommandText = sql;
try
{
str=(string)cmd.ExecuteScalar();
return str;
}
catch(SqlException e)
{
throw new Exception("执行SQL语句时出现问题"+e.Message );

}
catch(Exception e)
{
throw e;
}
finally
{
Dispose();
}

}

//把tableName表中的数据填充到数据集dataSet中，成功返回true
public bool Select(DataSet dataSet, string tableName, string queryString)
{
//若连接数据库失败则产生异常
if (!ConnectDb())
{
throw new Exception("数据库没有连接。");
}

try
{
//执行SQL语句,并将执行结果填充到DataSet的表中
cmd.CommandType = System.Data.CommandType.Text;
cmd.CommandText = queryString;
SqlDataAdapter adapter = new SqlDataAdapter();
adapter.SelectCommand = cmd;
adapter.Fill(dataSet,tableName);
return true;
}
catch(SqlException e)
{
throw new Exception("数据库错误。"+e.Message );

}
catch(Exception ex)
{
throw ex;
}
finally
{
Dispose();
}

}


// 查询数据库，返回查询结果表,SQL查询语句,成功返回查询结构表，失败返回null
public DataTable Select(String l_sQuery,String l_sTableName )
{
String sql = l_sQuery;
String sTableName = l_sTableName;

//若连接数据库失败则返回空
if (!ConnectDb())
{
throw new Exception ("数据库连接失败");;
}

DataSet cDataSet = new DataSet();
try
{
//执行SQL语句,并将执行结果充到DataSet的表中
cmd.CommandType = System.Data.CommandType.Text;
cmd.CommandText = sql;
SqlDataAdapter adapter = new SqlDataAdapter();
adapter.SelectCommand = cmd;
adapter.Fill(cDataSet,sTableName);
}
catch(SqlException e)
{
throw e;

}
finally
{
Dispose();
}
DataTable tempTable = cDataSet.Tables[sTableName];
cDataSet.Tables.Remove(sTableName);//从集合中移除该DataTable
return tempTable;

}


//开启事务
public void StartTransation()
{
//若连接数据库失败抛出错误
if (!ConnectDb())
{
throw(new ApplicationException("没有建立数据库连接。"));
}

this._isStartTransaction = true;
this._sqlTransaction = con.BeginTransaction(IsolationLevel.ReadCommitted);
cmd.Transaction = _sqlTransaction;

}


// 当前待处理事务提交，失败全部回滚, 成功提交返回true
public bool Commit()
{
//如果没有开启事务处理功能，不做任何操作，直接返回成功
if (!_isStartTransaction)
{
return true;
}
try
{
_sqlTransaction.Commit();
}
catch(SqlException e)
{
_sqlTransaction.Rollback();
throw e;
}
return true;
}

//调用三个参数存储过程,返回一个表
public DataTable RunProcedure(string procName,string pName1,string pValue1,
string pName2,string pValue2,string pName3,string pValue3)
{
//若连接数据库失败抛出错误
if (!ConnectDb())
{
throw(new ApplicationException("没有建立数据库连接。"));
}
try
{
cmd=new SqlCommand (procName,con);
cmd.CommandType =CommandType.StoredProcedure ;

//创建输入参数
SqlParameter sq1=new SqlParameter(pName1,SqlDbType.Int);
sq1.Direction =ParameterDirection.Input ;
sq1.Value =pValue1;
cmd.Parameters .Add (sq1);

SqlParameter sq2=new SqlParameter(pName2,SqlDbType.VarChar);
sq1.Direction =ParameterDirection.Input ;
sq1.Value =pValue2;
cmd.Parameters .Add (sq2);

SqlParameter sq3=new SqlParameter(pName3,SqlDbType.VarChar);
sq1.Direction =ParameterDirection.Input ;
sq1.Value =pValue3;
cmd.Parameters .Add (sq3);

// //创建输出参数
// SqlParameter spid=new SqlParameter ("@spid",SqlDbType.VarChar,20);
// spid.Direction =ParameterDirection.Output ;
// sqlCmd.Parameters .Add (spid);//
// //创建接收返回值的参数
// SqlParameter sReturn=new SqlParameter ("@RETURN_VALUE",SqlDbType.Int);
// sReturn.Direction =ParameterDirection.ReturnValue ;
// sqlCmd.Parameters .Add (sReturn);

SqlDataAdapter da=new SqlDataAdapter ();
da.SelectCommand=cmd;
DataSet ds1=new DataSet ();
da.Fill (ds1);
return ds1.Tables[0];
}
catch(Exception e)
{
throw e;
}
finally
{
Dispose();
}

}

//调用储过程（存储过程名，参数名，参数值，参数类型）
public DataTable RunProcedure(string procName,string pName,string pValue,SqlDbType type)
{
//若连接数据库失败抛出错误
if (!ConnectDb())
{
throw(new ApplicationException("没有建立数据库连接。"));
}
try
{
cmd=new SqlCommand (procName,con);
cmd.CommandType =CommandType.StoredProcedure ;

//创建输入参数
SqlParameter sq1=new SqlParameter(pName,type);
sq1.Direction =ParameterDirection.Input ;
sq1.Value =pValue;
cmd.Parameters .Add (sq1);

SqlDataAdapter da=new SqlDataAdapter ();
da.SelectCommand=cmd;
DataSet ds1=new DataSet ();
da.Fill (ds1);
return ds1.Tables[0];
}
catch(Exception e)
{
throw e;
}
finally
{
Dispose();
}

}


// 关闭数据库，释放数据库资源,成功返回true
public bool CloseDb()
{
//释放资源
Dispose();
return true;
}


//自定义释放资源，断掉连接。
public virtual void Dispose(bool disposing)
{
if (! disposing)
return;
//如果数据库处于连接状态,则进行断库及释放资源的操作
if (isCon)
{
if (con.State != ConnectionState.Closed )
{
con.Dispose();
con.Close();
cmd = null;
con = null;
_sqlTransaction=null;
isCon = false;
}
}
}

// 除去对象资源.
public void Dispose()
{
//调用带参数的释放资源方法
Dispose(true);

GC.SuppressFinalize(true);
}

}
}

A类是A数据库；B类是B数据库。 A按钮调用A语句查询A数据库，B按钮调用B语句查询B数据库，A的时间里面就去调A连接，B的时间里面就去调B连接

---

金昌市15980463518： 怎么在一个项目中连接两个数据库? - ？
咎忠强力： A类是A数据库;B类是B数据库. A按钮调用A语句查询A数据库,B按钮调用B语句查询B数据库,A的时间里面就去调A连接,B的时间里面就去调B连接

金昌市15980463518： 一个项目想同时连接两个数据库. - ？
咎忠强力： 用分布式数据同步,mysql提供分布式数据同步功能,spring也很容易配置,详细资料,网上查查,mysql的doc中也提供例子.

金昌市15980463518： 如何同时连接两个数据库 - ？
咎忠强力： 这个自己定义一个事务就行了.咱们一般平时开发的时候,可能很少定义事务.经常使用默认的SQLCA,这个SQLCA都是 你连接的主数据库,同样的,你在定义一个transaction,连接的参数,参照SQLCA的参数,把参数都设置成另一个数据库,就可以了.

金昌市15980463518： 如何在一个ASP文件中同时连接两个SQL数据库 - ？
咎忠强力： 用两个Connection对象去分别连接两个数据库,然后在建立RecordSet对象时分别对应不同的Connection对象即可.

金昌市15980463518： 一个ASP页面怎么连接两个数据库? - ？
咎忠强力： 完全可以连接两个数据库的,应该不会有什么问题,但不可以对一个数据库两进行同时两次以上的连接.比如我想同时连接一个数据库中的两个表,这样是不可能作到的,只能是先连接一个同连接一个,没有看到你的错误更离谱的了,连接两个...

金昌市15980463518： 一个java工程如何连接两个数据库 - ？
咎忠强力： 可以的,使用jdbc的链接代码,在你需要的地方建立两个连接即可.每个连接连接到一个数据库.

金昌市15980463518： myeclipse里一个项目怎样关联两个数据库 - ？
咎忠强力： 用分布式事务管理,

金昌市15980463518： 求助:如何在一个项目中使用多个SQL数据库? - ？
咎忠强力： 相信你这样一系统,肯定用了三层架构的模式,这样的话就好解决了,在数据访问层专一个连接数据库的有参方法.在调用该方法时传递不同数据库名即可,当然,每次在数据库访问层操作后一定要断掉数据连接,对一些实例清空回收,这很重...

金昌市15980463518： 一个java项目怎么连接两个不同的数据库 - ？
咎忠强力： 02-- 这是java环境,里有插件其全,javase,javaee,javame都可以,还有你所说的java项目框架直接020202 用他自己集成环境就能生成2.数据库你要是为了省事直接下一个mysql就行了,50多兆,不比 微软的slqserver系列的差 SSH框架中的持久...

金昌市15980463518： 在ASP中如何同时与两个数据库连接.要代码 - ？
咎忠强力： 建立两个不用的连接对象conn1和conn2,分别用来连接数据库1和数据库2,我写的例子是ACCESS数据库,可以根据你的需要修改为SQL Server的.set conn1=server.CreateObject(＂adodb.connection＂) set conn2=server.CreateObject(＂...