需要有两个配置文件。
1. mysql 数据库映射:
A.driverClassName=com.mysql.jdbc.Driver
A.url=jdbc:mysql://172.20.7.51:3308/blog
A.username=trappuser
A.password=Opera1!
B.driverClassName=com.mysql.jdbc.Driver
B.url=jdbc:mysql://localhost:3306/wedding
B.username=root
B.password=opera
上面定义的A、B为两个mysql instance的缩写。
2. 存储过程与mysql instance的映射关系:
SP_Get_User=A
GetStocks=B
定义两个模拟存储过程,第一个数据库“SP_Get_User“是在数据库A下面,第二个数据库”GetStocks“是在数据库B下面。
3. 建立自定义的sessionFactory
3.1 xml配置的datasource及sessionFactory如下:
<bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" id="dataSource">
<property name="driverClassName" value="${database.driverClassName}"/>
<property name="url" value="${database.url}"/>
<property name="username" value="${database.username}"/>
<property name="password" value="${database.password}"/>
</bean>
<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource"/>
<property name="packagesToScan" value="com.xx.assetcommander">
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
</props>
</property>
</bean>
查询方法public static DataSet ExecuteMySql(string strSQL)
{
//这里做些修改
MySqlConnection con = new MySqlConnection(“Host = 192.168.0.10Port = 3306User Id=rootPassword=1234Persist Security Info=TrueDatabase=smsprodb_mysql”)
MySqlDataAdapter da = new MySqlDataAdapter(你的sql语句, con)
DataSet ds = new DataSet()
da.Fill(ds)
con.Close()
return ds
}
增删改方法
public static DataSet UpdataMySql(string strSQL)
{
//这里做些修改
MySqlConnection con = new MySqlConnection(“Host = 192.168.0.10Port = 3306User Id=rootPassword=1234Persist Security Info=TrueDatabase=smsprodb_mysql”)
MySqlcommand sqlcom=new MySqlcommand ()
sqlcom.Connection=con
sqlcom.CommandString=“你的sql语句"
sqlconnect.open()
DataReader dr=sqlcom.ExecuteReader()
int x=sqlcom.ExecuteNonQuery()
con.Close();
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)