Quellcode durchsuchen

使用ipu-database跑通数据接口

weihf vor 6 Jahren
Ursprung
Commit
bac07c34ef

+ 1 - 1
ipu-server-demo/src/main/java/com/ai/ipu/server/bean/LoginBean.java

@ -79,7 +79,7 @@ public class LoginBean extends IpuAppBean {
79 79
	 */
80 80
	public IData getUserInfoByUserId(IData param) throws Exception{
81 81
	    IData resultData = new DataMap();
82
	    UserDao userDao = new UserDao("mysqlName");
82
	    UserDao userDao = new UserDao("test");
83 83
	    IData userObj = userDao.queryUserListByEmail(param);
84 84
	    resultData.put("user", userObj);
85 85
	    return resultData;

+ 11 - 5
ipu-server-demo/src/main/java/com/ai/ipu/server/dao/UserDao.java

@ -1,9 +1,12 @@
1 1
package com.ai.ipu.server.dao;
2 2

3
import com.ai.ipu.server.db.dao.impl.BaseDAO;
3
import java.util.Map;
4

5
import com.ai.ipu.database.dao.impl.AbstractBizDao;
4 6
import com.ailk.common.data.IData;
7
import com.ailk.common.data.impl.DataMap;
5 8

6
public class UserDao extends BaseDAO
9
public class UserDao extends AbstractBizDao
7 10
{
8 11
    public UserDao(String connName) throws Exception
9 12
    {
@ -15,8 +18,11 @@ public class UserDao extends BaseDAO
15 18
     */
16 19
    public IData queryUserListByEmail(IData param) throws Exception
17 20
    {
18
        String sql = " SELECT * FROM user WHERE email = :USER_EMAIL";
19
        return this.queryList(sql, param).first();
21
    	IData resultData = new DataMap();
22
        String sql = " SELECT * FROM tab_user_info WHERE USER_EMAIL = #{USER_EMAIL}";
23
        Map result =  this.getBasicDao().executeSelectOne(sql, param);
24
        resultData.putAll(result);
25
        return resultData;
20 26
    }
21 27

22 28
    /**
@ -25,7 +31,7 @@ public class UserDao extends BaseDAO
25 31
    public void insertUsers(IData param) throws Exception
26 32
    {
27 33
        String sql = "INSERT INTO user (email, encrypted_password, created_at, updated_at, name, state) VALUES(:email, :encrypted_password, :created_at, :updated_at, :name, :state)";
28
        this.executeUpdate(sql, param);
34
        this.getBasicDao().executeUpdate(sql, param);
29 35
    }
30 36

31 37
}

+ 1 - 1
ipu-server-demo/src/main/resources/dev/ipu-mybatis-config.xml

@ -18,7 +18,7 @@
18 18
			<transactionManager type="JDBC" />
19 19
			<dataSource type="com.ai.ipu.database.datasource.C3P0DataSourceFactory">
20 20
				<property name="driverClass" value="com.mysql.jdbc.Driver" />
21
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/test" />
21
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/test_app_mgmt" />
22 22
				<property name="user" value="ipu" />
23 23
				<property name="password" value="ipumysql" />
24 24
				<!-- 连接池用完时,等待获取新连接的时间 (毫秒) -->

+ 1 - 0
ipu-server-demo/src/main/resources/server-data.xml

@ -3,5 +3,6 @@
3 3
    <action name="Login.init" class="com.ai.ipu.server.bean.LoginBean" method="init" verify="false"></action>
4 4
    <action name="Login.refreshVerifyCode" class="com.ai.ipu.server.bean.LoginBean" method="refreshVerifyCode" verify="false"></action>
5 5
    <action name="Login.doLogin" class="com.ai.ipu.server.bean.LoginBean" method="doLogin" verify="false"></action>
6
    <action name="Login.getUserInfoByUserId" class="com.ai.ipu.server.bean.LoginBean" method="getUserInfoByUserId" verify="false"></action>
6 7
    <action name="Index.getMenuData" class="com.ai.ipu.server.bean.IndexBean" method="getMenuData" verify="false"></action>
7 8
</datas>