提交 90c1acd3 编写于 作者: F Frankie Wu

fix session issue

上级 34ffbd7a
......@@ -12,8 +12,10 @@ import com.dianping.bee.engine.spi.TableProviderManager;
import com.dianping.bee.engine.spi.handler.AbstractCommandHandler;
import com.dianping.bee.engine.spi.meta.ColumnMeta;
import com.dianping.bee.engine.spi.meta.internal.TypeUtils;
import com.site.lookup.annotation.Inject;
public class DescHandler extends AbstractCommandHandler {
@Inject
private TableProviderManager m_manager;
@Override
......
......@@ -76,9 +76,14 @@ public class SimpleServerConnection extends ServerConnection {
}
@Override
public void setSchema(String schema) {
super.setSchema(schema);
m_sessionManager.getSession().setDatabase(schema);
public void query(byte[] data) {
m_sessionManager.getSession().setDatabase(getSchema());
try {
super.query(data);
} finally {
m_sessionManager.removeSession();
}
}
public void setSessionManager(SessionManager sessionManager) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册