Skip to content

Commit

Permalink
adjust db interface
Browse files Browse the repository at this point in the history
  • Loading branch information
samuelchen committed Mar 7, 2012
1 parent 71d563c commit 523e1cb
Show file tree
Hide file tree
Showing 11 changed files with 45 additions and 47 deletions.
Expand Up @@ -37,7 +37,7 @@ public APIResponse Invoke(APIRequest req) {
Map<String, String> resp_headers = resp.getHeaders();

ScssBucket scssBucket=null;
scssBucket = ScssBucketDaoImpl.getInstance().getBucket(req.BucketName);
scssBucket = ScssBucketDaoImpl.getInstance().get(req.BucketName);

if(null!= scssBucket)
{
Expand All @@ -51,7 +51,7 @@ public APIResponse Invoke(APIRequest req) {
else
{
try {
ScssBucketDaoImpl.getInstance().deleteBucket(scssBucket);
ScssBucketDaoImpl.getInstance().delete(scssBucket);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
Expand Down
Expand Up @@ -54,7 +54,7 @@ public APIResponse Invoke(APIRequest req) {
// TODO: Use Bucket instead ScssBucket. temporary using.

ScssBucket bucket=null;
bucket = ScssBucketDaoImpl.getInstance().getBucket(req.BucketName);
bucket = ScssBucketDaoImpl.getInstance().get(req.BucketName);
if (null == bucket)
return ErrorResponse.NoSuchBucket(req);
List<ScssObject> bucket_objects=null;
Expand Down
Expand Up @@ -36,7 +36,7 @@ public APIResponse Invoke(APIRequest req) {
APIResponse resp = new BucketAPIResponse();
Map<String, String> resp_headers = resp.getHeaders();

ScssBucket scssBucket=ScssBucketDaoImpl.getInstance().getBucket(req.BucketName) ;
ScssBucket scssBucket=ScssBucketDaoImpl.getInstance().get(req.BucketName) ;

if(null!=scssBucket)
{
Expand Down
Expand Up @@ -21,7 +21,7 @@ public class ScssBucketDaoImpl implements IBucket{
private ScssBucketDaoImpl() {
}
@Override
public ScssBucket insertBucket(ScssBucket bucket) throws SameNameException,
public ScssBucket insert(ScssBucket bucket) throws SameNameException,
SQLException {
try {
bucket.setId((Long) sqlMap.insert("putBucket", bucket));
Expand Down Expand Up @@ -50,17 +50,17 @@ public ScssBucket get(ScssBucket sb) {
}
return null;
}
// @Override
// public List<ScssBucket> get() {
// try {
// return sqlMap.queryForList("getBuckets");
// } catch (SQLException e) {
// e.printStackTrace();
// }
// return null;
// }
@Override
public List<ScssBucket> get() {
try {
return sqlMap.queryForList("getBuckets");
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
@Override
public List<ScssBucket> getByUser(ScssUser user) {
public List<ScssBucket> getAll(ScssUser user) {
try {
return sqlMap.queryForList("getBucketsByUser", user);
} catch (SQLException e) {
Expand Down
Expand Up @@ -26,7 +26,7 @@ public static ScssGroupDaoImpl getInstance() {
}

@Override
public ScssGroup getGroupById(Long groupId) {
public ScssGroup get(Long groupId) {
ScssGroup su = null;
try {
su = (ScssGroup) sqlMap.queryForObject("getGroupById", groupId);
Expand Down
Expand Up @@ -43,7 +43,7 @@ public List getUserList() {
}

@Override
public void deleteUser(ScssUser user) throws DBException {
public void delete(ScssUser user) throws DBException {
try {
sqlMap.delete("deleteUser", user.getId());
} catch (SQLException e) {
Expand All @@ -52,7 +52,7 @@ public void deleteUser(ScssUser user) throws DBException {
}

@Override
public void deleteUser(Long id) throws DBException {
public void delete(Long id) throws DBException {
try {
sqlMap.delete("deleteUser", id);
} catch (SQLException e) {
Expand All @@ -61,7 +61,7 @@ public void deleteUser(Long id) throws DBException {
}

@Override
public ScssUser insertUser(ScssUser user) throws SameNameException {
public ScssUser insert(ScssUser user) throws SameNameException {
try {
user.setId((Long) sqlMap.insert("putUser", user));
} catch (com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException e) {
Expand Down Expand Up @@ -132,13 +132,13 @@ public List<ScssUser> getUsersByGroup(ScssGroup group) {
}
String[] split = userIds.split(",");
for (int i = 1; i < split.length; ++i) {
result.add(getUserById(Long.parseLong(split[i])));
result.add(get(Long.parseLong(split[i])));
}
return result;
}

@Override
public ScssUser getUserById(long id) {
public ScssUser get(long id) {
ScssUser su = null;
try {
su = (ScssUser) sqlMap.queryForObject("getUserById", id);
Expand All @@ -160,7 +160,7 @@ public ScssUser getUserBySohuId(String sohuId) {
}

@Override
public void updateUser(ScssUser scssUser) throws DBException {
public void update(ScssUser scssUser) throws DBException {
try {
sqlMap.update("updateUser", scssUser);
} catch (SQLException e) {
Expand Down
Expand Up @@ -9,17 +9,15 @@

public interface IBucket {

ScssBucket insertBucket(ScssBucket bucket) throws SameNameException,
ScssBucket insert(ScssBucket bucket) throws SameNameException,
SQLException;

ScssBucket get(Long id);

List<ScssBucket> getByUser(ScssUser user);
List<ScssBucket> getAll(ScssUser user);

ScssBucket get(ScssBucket sb);

List<ScssBucket> get();

void delete(ScssBucket sb) throws SQLException;

void update(ScssBucket sb) throws SQLException;
Expand Down
@@ -1,6 +1,5 @@
package com.scss.db.dao.i;

import java.sql.SQLException;
import java.util.List;

import com.scss.db.exception.DBException;
Expand All @@ -9,9 +8,10 @@

public interface IGroup {

ScssGroup getGroupById(Long groupId);
ScssGroup get(Long groupId);

List<ScssGroup> getGroupByName(String name);
List<ScssGroup> getAll(Long user_id);
List<ScssGroup> getAll(String access_id);

ScssGroup insert(ScssGroup group);

Expand Down
14 changes: 7 additions & 7 deletions src/StorageWorkspace/StorageAPI/src/com/scss/db/dao/i/IUser.java
Expand Up @@ -9,13 +9,13 @@

public interface IUser {

List getUserList();
List<ScssUser> getUserList();

void deleteUser(ScssUser user) throws DBException;
void delete(ScssUser user) throws DBException;

void deleteUser(Long id) throws DBException;
void delete(Long id) throws DBException;

ScssUser insertUser(ScssUser user) throws SameNameException;
ScssUser insert(ScssUser user) throws SameNameException;

ScssUser getUserByAccessKey(String access_key);

Expand All @@ -25,10 +25,10 @@ public interface IUser {

List<ScssUser> getUsersByGroup(ScssGroup group);

ScssUser getUserById(long id);
ScssUser get(long id);

ScssUser getUserBySohuId(String sohuId);
List<ScssUser> getUsersBySohuId(String sohuId);

void updateUser(ScssUser scssUser) throws DBException;
void update(ScssUser scssUser) throws DBException;

}
Expand Up @@ -39,23 +39,23 @@ public static void main(String args[]) throws SameNameException,
user.setSohuId("sohuId");
user.setAccessId("accessId");
user.setAccessKey("accessKey");
user = sud.insertUser(user);
user = sud.insert(user);
user.setAccessKey("aaaa&&&&&a");
sud.updateUser(user);
user = sud.getUserById(user.getId());
user = sud.getUserById(user.getId());
sud.update(user);
user = sud.get(user.getId());
user = sud.get(user.getId());
user = sud.getUserBySohuId("sohuId");
user = sud.getUserByAccessKey("aaaa&&&&&a");

// Test Group
ScssGroupDaoImpl sgd = ScssGroupDaoImpl.getInstance();
ScssGroup group = new ScssGroup();
group.setName("Óû§×é");
group.setName("�û���");
group.setOwnerId(user.getId());
group = sgd.insert(group);
List<ScssGroup> groups = sgd.getGroupByName(group.getName());
group = sgd.getGroupByName(group.getName(), user.getId());
group = sgd.getGroupById(group.getId());
group = sgd.get(group.getId());
group.setName(group.getName() + "1");
sgd.update(group);

Expand All @@ -67,14 +67,14 @@ public static void main(String args[]) throws SameNameException,

// Test Bucket
ScssBucketDaoImpl sbd = ScssBucketDaoImpl.getInstance();
List<ScssBucket> bucketsByUser = sbd.getByUser(user);
List<ScssBucket> bucketsByUser = sbd.getAll(user);
ScssBucket bucket = new ScssBucket();
bucket.setName("test_bucket");
bucket.setOwnerId(1l);
bucket.setMeta("Meta_test");
bucket.setDeleted((byte) 0);
bucket.setLoggingEnabled((byte) 1);
bucket = sbd.insertBucket(bucket);
bucket = sbd.insert(bucket);
bucket = sbd.get(bucket.getName());
bucket = sbd.get(bucket.getId());
bucket = sbd.get(bucket);
Expand Down Expand Up @@ -111,7 +111,7 @@ public static void main(String args[]) throws SameNameException,
sad.update(acl);
acl = sad.get(acl.getId());

// Test Log ÔÝʱ²»²âÊÔ
// Test Log ��ʱ������
// ScssLogDaoImpl sld = ScssLogDaoImpl.getInstance();
// ScssLog log = new ScssLog();
// log
Expand All @@ -133,7 +133,7 @@ public static void main(String args[]) throws SameNameException,
sbld.delete(sbl);
sbd.delete(bucket);
sgd.delete(group);
sud.deleteUser(user);
sud.delete(user);
sad.delete(acl);

}
Expand Down
Expand Up @@ -9,6 +9,6 @@ public class ScssUserServiceImpl implements ScssUserService {
private ScssUserDaoImpl sudi = ScssUserDaoImpl.getInstance();

public ScssUser putUser(ScssUser user) throws SameNameException {
return sudi.insertUser(user);
return sudi.insert(user);
}
}

0 comments on commit 523e1cb

Please sign in to comment.