Converting CompanyUser model to hibernate entity (#670)

* Converting one of the wherehows-frontend model to hibernate

* Converting few models and UserDAO to use hibernate
This commit is contained in:
Shridhar Sattur 2017-08-16 21:24:01 -07:00 committed by Mars Lan
parent 336b750d17
commit cc1699761e
11 changed files with 97 additions and 46 deletions

View File

@ -13,8 +13,23 @@
*/ */
package wherehows.models; package wherehows.models;
import lombok.AllArgsConstructor;
import lombok.Data;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
@Data
@Entity
@Table(name = "dir_external_user_info")
public class CompanyUser { public class CompanyUser {
public String userName; @Id
public String displayName; @Column(name = "user_id")
private String userName;
@Column(name = "display_name")
private String displayName;
} }

View File

@ -13,7 +13,19 @@
*/ */
package wherehows.models; package wherehows.models;
import lombok.Data;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
@Data
@Entity
@Table(name = "dir_external_group_user_map")
public class Group { public class Group {
public String name; @Id
@Column(name = "group_id")
private String name;
} }

View File

@ -13,12 +13,33 @@
*/ */
package wherehows.models; package wherehows.models;
import lombok.Data;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
@Data
@Entity
@Table(name = "users")
public class User { public class User {
public int id; @Id
public String userName; // ldap user id @Column(name = "id")
public int departmentNum; private int id;
public String email;
public String name; // ldap display name @Column(name = "username")
public UserSetting userSetting; private String userName; // ldap user id
@Column(name = "department_number")
private int departmentNum;
@Column(name = "email")
private String email;
@Column(name = "name")
private String name; // ldap display name
UserSetting userSetting;
} }

View File

@ -13,8 +13,11 @@
*/ */
package wherehows.models; package wherehows.models;
import lombok.Data;
@Data
public class UserSetting { public class UserSetting {
public String detailDefaultView; private String detailDefaultView;
public String defaultWatch; private String defaultWatch;
} }

View File

@ -43,7 +43,7 @@ public class User extends Controller {
} }
wherehows.models.User user = UserDAO.getCurrentUser(username); wherehows.models.User user = UserDAO.getCurrentUser(username);
if (StringUtils.isBlank(user.userName)) { if (StringUtils.isBlank(user.getUserName())) {
result.put("status", "failed"); result.put("status", "failed");
result.put("message", "can't find user info"); result.put("message", "can't find user info");
return ok(result); return ok(result);

View File

@ -78,9 +78,9 @@ public class DatasetRowMapper implements RowMapper<Dataset>
for (int i = 0; i < owners.length; i++) for (int i = 0; i < owners.length; i++)
{ {
User user = new User(); User user = new User();
user.userName = owners[i]; user.setUserName(owners[i]);
user.name = ownerNames[i]; user.setName(ownerNames[i]);
user.email = ownerEmail[i]; user.setEmail(ownerEmail[i]);
dataset.owners.add(user); dataset.owners.add(user);
} }
} }

View File

@ -80,9 +80,9 @@ public class DatasetWithUserRowMapper implements RowMapper<Dataset>
for (int i = 0; i < owners.length; i++) for (int i = 0; i < owners.length; i++)
{ {
User user = new User(); User user = new User();
user.userName = owners[i]; user.setUserName(owners[i]);
user.name = ownerNames[i]; user.setName(ownerNames[i]);
user.email = ownerEmail[i]; user.setEmail(ownerEmail[i]);
dataset.owners.add(user); dataset.owners.add(user);
} }
} }

View File

@ -501,18 +501,18 @@ public class DatasetsDAO extends AbstractMySQLOpenSourceDAO
for (int i = 0; i < owners.length; i++) for (int i = 0; i < owners.length; i++)
{ {
User datasetOwner = new User(); User datasetOwner = new User();
datasetOwner.userName = owners[i]; datasetOwner.setUserName(owners[i]);
if (datasetOwner.userName.equalsIgnoreCase(user)) if (datasetOwner.getUserName().equalsIgnoreCase(user))
{ {
ds.isOwned = true; ds.isOwned = true;
} }
if (StringUtils.isBlank(ownerNames[i]) || ownerNames[i].equalsIgnoreCase("*")) if (StringUtils.isBlank(ownerNames[i]) || ownerNames[i].equalsIgnoreCase("*"))
{ {
datasetOwner.name = owners[i]; datasetOwner.setName(owners[i]);
} }
else else
{ {
datasetOwner.name = ownerNames[i]; datasetOwner.setName(ownerNames[i]);
} }
ds.owners.add(datasetOwner); ds.owners.add(datasetOwner);
} }
@ -678,8 +678,8 @@ public class DatasetsDAO extends AbstractMySQLOpenSourceDAO
dislayName = ownerId; dislayName = ownerId;
} }
User owner = new User(); User owner = new User();
owner.userName = ownerId; owner.setUserName(ownerId);
owner.name = dislayName; owner.setName(dislayName);
owners.add(owner); owners.add(owner);
} }
if (result) if (result)
@ -717,8 +717,8 @@ public class DatasetsDAO extends AbstractMySQLOpenSourceDAO
dislayName = ownerId; dislayName = ownerId;
} }
User owner = new User(); User owner = new User();
owner.userName = ownerId; owner.setUserName(ownerId);
owner.name = dislayName; owner.setName(dislayName);
owners.add(owner); owners.add(owner);
int updatedRows = getJdbcTemplate().update(UPDATE_DATASET_OWNER_SORT_ID, sortId++, id, ownerId, namespace); int updatedRows = getJdbcTemplate().update(UPDATE_DATASET_OWNER_SORT_ID, sortId++, id, ownerId, namespace);
if (ret <= 0) if (ret <= 0)

View File

@ -112,13 +112,13 @@ public class UserDAO extends AbstractMySQLOpenSourceDAO
public static void addLdapUser(User user) public static void addLdapUser(User user)
{ {
if (user != null && StringUtils.isNotBlank(user.userName)) if (user != null && StringUtils.isNotBlank(user.getUserName()))
{ {
getJdbcTemplate().update(CREATE_LDAP_USER, getJdbcTemplate().update(CREATE_LDAP_USER,
user.name, user.getName(),
user.userName, user.getUserName(),
user.email, user.getEmail(),
user.departmentNum); user.getDepartmentNum());
} }
} }
@ -284,8 +284,8 @@ public class UserDAO extends AbstractMySQLOpenSourceDAO
String displayName = (String) row.get(UserRowMapper.USER_FULL_NAME_COLUMN); String displayName = (String) row.get(UserRowMapper.USER_FULL_NAME_COLUMN);
if (StringUtils.isNotBlank(userName)) { if (StringUtils.isNotBlank(userName)) {
CompanyUser user = new CompanyUser(); CompanyUser user = new CompanyUser();
user.userName = userName; user.setUserName(userName);
user.displayName = displayName; user.setDisplayName(displayName);
users.add(user); users.add(user);
} }
} }
@ -301,7 +301,7 @@ public class UserDAO extends AbstractMySQLOpenSourceDAO
String name = (String) row.get(UserRowMapper.USER_FULL_NAME_COLUMN); String name = (String) row.get(UserRowMapper.USER_FULL_NAME_COLUMN);
if (StringUtils.isNotBlank(name)) { if (StringUtils.isNotBlank(name)) {
Group group = new Group(); Group group = new Group();
group.name = name; group.setName(name);
groups.add(group); groups.add(group);
} }
} }

View File

@ -44,14 +44,14 @@ public class UserRowMapper implements RowMapper<User>
User user = new User(); User user = new User();
UserSetting userSetting = new UserSetting(); UserSetting userSetting = new UserSetting();
userSetting.detailDefaultView = defaultView; userSetting.setDetailDefaultView(defaultView);
userSetting.defaultWatch = defaultWatch; userSetting.setDefaultWatch(defaultWatch);
user.id = id; user.setId(id);
user.name = name; user.setName(name);
user.email = email; user.setEmail(email);
user.userName = username; user.setUserName(username);
user.departmentNum = departmentNum; user.setDepartmentNum(departmentNum);
user.userSetting = userSetting; user.setUserSetting(userSetting);
return user; return user;
} }

View File

@ -177,10 +177,10 @@ public class AuthenticationManager {
} }
} }
User user = new User(); User user = new User();
user.email = email; user.setEmail(email);
user.userName = userName; user.setUserName(userName);
user.name = firstName + " " + lastName; user.setName(firstName + " " + lastName);
user.departmentNum = departmentNum; user.setDepartmentNum(departmentNum);
return user; return user;
} }
} }