Examples of securityOperations()

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

531
532
533
534
535
536
537
538
539
540
541
      Connector c = getInstance(implementingClass, conf).getConnector(getPrincipal(implementingClass, conf),
          CredentialHelper.extractToken(getTokenClass(implementingClass, conf), getToken(implementingClass, conf)));
      if (!c.securityOperations().authenticateUser(getPrincipal(implementingClass, conf),
          CredentialHelper.extractToken(getTokenClass(implementingClass, conf), getToken(implementingClass, conf))))
        throw new IOException("Unable to authenticate user");
      if (!c.securityOperations().hasTablePermission(getPrincipal(implementingClass, conf), getInputTableName(implementingClass, conf), TablePermission.READ))
        throw new IOException("Unable to access table");
     
      if (!conf.getBoolean(enumToConfKey(implementingClass, Features.USE_LOCAL_ITERATORS), false)) {
        // validate that any scan-time iterators can be loaded by the the tablet servers
        for (IteratorSetting iter : getIterators(implementingClass, conf)) {
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

518
519
520
521
522
523
524
525
526
527
528
      throw new IOException("Output info has not been set.");
    if (!conf.getBoolean(INSTANCE_HAS_BEEN_SET, false))
      throw new IOException("Instance info has not been set.");
    try {
      Connector c = getInstance(job).getConnector(getUsername(job), getPassword(job));
      if (!c.securityOperations().authenticateUser(getUsername(job), getPassword(job)))
        throw new IOException("Unable to authenticate user");
    } catch (AccumuloException e) {
      throw new IOException(e);
    } catch (AccumuloSecurityException e) {
      throw new IOException(e);
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

83
84
85
86
87
88
89
90
91
92
93
  }
 
  @Test
  public void testChangeAuths() throws Exception {
    Connector c = new MockConnector("root", new MockInstance());
    c.securityOperations().createUser("greg", new byte[] {}, new Authorizations("A", "B", "C"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
    c.securityOperations().changeUserAuthorizations("greg", new Authorizations("X", "Y", "Z"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("X".getBytes()));
    assertFalse(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
  }
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

84
85
86
87
88
89
90
91
92
93
94
 
  @Test
  public void testChangeAuths() throws Exception {
    Connector c = new MockConnector("root", new MockInstance());
    c.securityOperations().createUser("greg", new byte[] {}, new Authorizations("A", "B", "C"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
    c.securityOperations().changeUserAuthorizations("greg", new Authorizations("X", "Y", "Z"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("X".getBytes()));
    assertFalse(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
  }
 
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

85
86
87
88
89
90
91
92
93
94
95
  @Test
  public void testChangeAuths() throws Exception {
    Connector c = new MockConnector("root", new MockInstance());
    c.securityOperations().createUser("greg", new byte[] {}, new Authorizations("A", "B", "C"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
    c.securityOperations().changeUserAuthorizations("greg", new Authorizations("X", "Y", "Z"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("X".getBytes()));
    assertFalse(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
  }
 
  @Test
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

86
87
88
89
90
91
92
93
94
95
96
  public void testChangeAuths() throws Exception {
    Connector c = new MockConnector("root", new MockInstance());
    c.securityOperations().createUser("greg", new byte[] {}, new Authorizations("A", "B", "C"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
    c.securityOperations().changeUserAuthorizations("greg", new Authorizations("X", "Y", "Z"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("X".getBytes()));
    assertFalse(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
  }
 
  @Test
  public void testBadMutations() throws Exception {
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

87
88
89
90
91
92
93
94
95
96
97
    Connector c = new MockConnector("root", new MockInstance());
    c.securityOperations().createUser("greg", new byte[] {}, new Authorizations("A", "B", "C"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
    c.securityOperations().changeUserAuthorizations("greg", new Authorizations("X", "Y", "Z"));
    assertTrue(c.securityOperations().getUserAuthorizations("greg").contains("X".getBytes()));
    assertFalse(c.securityOperations().getUserAuthorizations("greg").contains("A".getBytes()));
  }
 
  @Test
  public void testBadMutations() throws Exception {
    Connector c = new MockConnector("root", new MockInstance());
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

76
77
78
79
80
81
82
83
84
85
86
    r.nextBytes(newPass);
    BigInteger bi = new BigInteger(newPass);
    newPass = bi.toString(36).getBytes();
   
    try {
      conn.securityOperations().changeUserPassword(target, newPass);
    } catch (AccumuloSecurityException ae) {
      switch (ae.getErrorCode()) {
        case PERMISSION_DENIED:
          if (hasPerm)
            throw new AccumuloException("Change failed when it should have succeeded to change " + target + "'s password", ae);
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

42
43
44
45
46
47
48
49
50
51
52
    systemUserName = String.format("system_%s_%s_%d", hostname, state.getPid(), System.currentTimeMillis());
    tableUserName = String.format("table_%s_%s_%d", hostname, state.getPid(), System.currentTimeMillis());
    secTableName = String.format("security_%s_%s_%d", hostname, state.getPid(), System.currentTimeMillis());
   
    byte[] sysUserPass = "sysUser".getBytes();
    conn.securityOperations().createUser(systemUserName, sysUserPass, new Authorizations());
    sysConn = instance.getConnector(systemUserName, sysUserPass);
   
    SecurityHelper.setSystemConnector(state, sysConn);
    SecurityHelper.setSysUserName(state, systemUserName);
    SecurityHelper.setSysUserPass(state, sysUserPass);
View Full Code Here

Examples of org.apache.accumulo.core.client.Connector.securityOperations()

86
87
88
89
90
91
92
93
94
95
96
   
    if (SecurityHelper.getTabUserExists(state)) {
      String tableUserName = SecurityHelper.getTabUserName(state);
      log.debug("Dropping user: " + tableUserName);
     
      conn.securityOperations().dropUser(tableUserName);
    }
    String systemUserName = SecurityHelper.getSysUserName(state);
    log.debug("Dropping user: " + systemUserName);
    conn.securityOperations().dropUser(systemUserName);
   
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.