summaryrefslogtreecommitdiff
path: root/src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java')
-rw-r--r--src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java25
1 files changed, 8 insertions, 17 deletions
diff --git a/src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java b/src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java
index 3124845..d7c7a21 100644
--- a/src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java
+++ b/src/YalpAuth/YalpPGSqlAuth/YalpAuthPluginImpl.java
@@ -93,40 +93,31 @@ public class YalpAuthPluginImpl extends AuthPluginInterfacePOA{
YalpError error = new YalpError ("auth ok", YalpErrorCode.OK,
YalpErrorLevel.ERROR_LEVEL_INFO, "authentication module working");
- try {
- String query = "select * from \"Users\" where \"name\" = '"+username+"' and \"passwd\" = '"+passwd+"';";
-
- ResultSet result = stat.executeQuery(query);
+ try{
+ ResultSet result=stat.executeQuery("select * from \"user\" where \"username\" = '"+username+"' and \"passwd\" = '"+passwd+"';");
if (result.next()){
- if (result.getInt(1)>1)
+ if (result.getBoolean(5)==true)
{
- user.value = new YalpUser
- (666, username, "real name", AccessRights.ADMIN);
+ user.value.level = AccessRights.ADMIN;
err.value = error;
return;
}
else
{
- user.value = new YalpUser
- (666, username, "real name", AccessRights.USER);
+ user.value.level = AccessRights.USER;
err.value = error;
return;
}
}
else
{
- user.value = new YalpUser
- (666, username, "real name", AccessRights.DENY);
+ user.value.level = AccessRights.DENY;
err.value = error;
return;
}
-
- } catch (SQLException e){
- System.out.println("SQL ExceptioN!\n");
- e.printStackTrace();
- user.value = new YalpUser
- (666, username, "real name", AccessRights.DENY);
+ }catch (SQLException e){
+ user.value.level = AccessRights.DENY;
error.code = YalpErrorCode.ERROR_SQL;
error.msg = "failed to send auth request to pgsql db";
error.level = YalpErrorLevel.ERROR_LEVEL_ERROR;