Guest User

Untitled

a guest
Jul 19th, 2018
89
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.26 KB | None | 0 0
  1. public class Connection {
  2.  
  3. public static Session getConnection() {
  4.  
  5. final Cluster cluster = Cluster.builder().addContactPoint(ConnectionBean.getCASSANDRA_DB_IP())
  6. .withQueryOptions(new QueryOptions().setConsistencyLevel(ConsistencyLevel.LOCAL_ONE))
  7. .withCredentials(ConnectionBean.getCASSANDRA_USER(), ConnectionBean.getCASSANDRA_PASSWORD())
  8. .withPoolingOptions(poolingOptions)
  9. .build();
  10. final Session session = cluster.connect(ConnectionBean.getCASSANDRA_DB_NAME());
  11. return session;
  12. }
  13.  
  14. public class ConnectionBean {
  15.  
  16. public static String CASSANDRA_DB_IP;
  17. public static String CASSANDRA_DB_NAME;
  18. public static String CASSANDRA_USER;
  19. public static String CASSANDRA_PASSWORD;
  20.  
  21. public ConnectionBean() {
  22.  
  23. }
  24. public ConnectionBean(String CASSANDRA_DB_IP,String CASSANDRA_DB_NAME,String CASSANDRA_USER,String CASSANDRA_PASSWORD) {
  25. this.CASSANDRA_DB_IP=CASSANDRA_DB_IP;
  26. this.CASSANDRA_DB_NAME=CASSANDRA_DB_NAME;
  27. this.CASSANDRA_USER=CASSANDRA_USER;
  28. this.CASSANDRA_PASSWORD=CASSANDRA_PASSWORD;
  29. }
  30.  
  31. public static String getCASSANDRA_DB_IP() {
  32. return CASSANDRA_DB_IP;
  33. }
  34. public static void setCASSANDRA_DB_IP(String cASSANDRA_DB_IP) {
  35. CASSANDRA_DB_IP = cASSANDRA_DB_IP;
  36. }
  37. public static String getCASSANDRA_DB_NAME() {
  38. return CASSANDRA_DB_NAME;
  39. }
  40. public static void setCASSANDRA_DB_NAME(String cASSANDRA_DB_NAME) {
  41. CASSANDRA_DB_NAME = cASSANDRA_DB_NAME;
  42. }
  43. public static String getCASSANDRA_USER() {
  44. return CASSANDRA_USER;
  45. }
  46. public static void setCASSANDRA_USER(String cASSANDRA_USER) {
  47. CASSANDRA_USER = cASSANDRA_USER;
  48. }
  49. public static String getCASSANDRA_PASSWORD() {
  50. return CASSANDRA_PASSWORD;
  51. }
  52. public static void setCASSANDRA_PASSWORD(String cASSANDRA_PASSWORD) {
  53. CASSANDRA_PASSWORD = cASSANDRA_PASSWORD;
  54. }
  55.  
  56. public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
  57. private static final String LOGIN_PROCESSING_URL = "/login";
  58. private static final String LOGIN_FAILURE_URL = "/login?error";
  59. private static final String LOGIN_URL = "/login";
  60.  
  61. @Autowired
  62. private BCryptPasswordEncoder bCryptPasswordEncoder;
  63.  
  64. @Autowired
  65. private DataSource dataSource;
  66.  
  67. @Value("${spring.queries.users-query}")
  68. private String usersQuery;
  69.  
  70. @Value("${spring.queries.roles-query}")
  71. private String rolesQuery;
  72.  
  73. @Value("${CASSANDRA_DB_IP}")
  74. public String CASSANDRA_DB_IP;
  75.  
  76. @Value("${CASSANDRA_DB_NAME}")
  77. public String CASSANDRA_DB_NAME;
  78.  
  79. @Value("${CASSANDRA_USER}")
  80. public String CASSANDRA_USER;
  81.  
  82. @Value("${CASSANDRA_PASSWORD}")
  83. public String CASSANDRA_PASSWORD;
  84.  
  85. @Override
  86. protected void configure(AuthenticationManagerBuilder auth) throws Exception {
  87. ConnectionBean cb = new ConnectionBean(CASSANDRA_DB_IP, CASSANDRA_DB_NAME, CASSANDRA_USER, CASSANDRA_PASSWORD);
  88.  
  89. auth.jdbcAuthentication().usersByUsernameQuery(usersQuery).authoritiesByUsernameQuery(rolesQuery)
  90. .dataSource(dataSource).passwordEncoder(bCryptPasswordEncoder);
  91. }
  92.  
  93. @Override
  94. protected void configure(HttpSecurity http) throws Exception {
  95. // Not using Spring CSRF here to be able to use plain HTML for the login page
  96.  
  97. http.csrf().disable()
  98.  
  99. // Register our CustomRequestCache, that saves unauthorized access attempts, so
  100. // the user is redirected after login.
  101. .requestCache().requestCache(new CustomRequestCache())
  102.  
  103. // Restrict access to our application.
  104. .and().authorizeRequests()
  105.  
  106. // Allow all flow internal requests.
  107. .requestMatchers(SecurityUtils::isFrameworkInternalRequest).permitAll()
  108.  
  109. // Allow all requests by logged in users.
  110. .anyRequest().authenticated()
  111.  
  112. // Configure the login page.
  113. .and().formLogin().loginPage(LOGIN_URL).permitAll().loginProcessingUrl(LOGIN_PROCESSING_URL)
  114. .failureUrl(LOGIN_FAILURE_URL)
  115.  
  116. // Register the success handler that redirects users to the page they last tried
  117. // to access
  118. .successHandler(new SavedRequestAwareAuthenticationSuccessHandler())
  119.  
  120. // Configure logout
  121. .and().logout().logoutSuccessUrl(LOGOUT_SUCCESS_URL);
  122. }
  123.  
  124. /**
  125. * Allows access to static resources, bypassing Spring security.
  126. */
  127. @Override
  128. public void configure(WebSecurity web) throws Exception {
  129. web.ignoring().antMatchers(
  130. // Vaadin Flow static resources
  131. "/VAADIN/**",
  132.  
  133. // the standard favicon URI
  134. "/favicon.ico",
  135.  
  136. // web application manifest
  137. "/manifest.json", "/sw.js", "/offline-page.html",
  138.  
  139. // icons and images
  140. "/icons/**", "/images/**",
  141.  
  142. // (development mode) static resources
  143. "/frontend/**",
  144.  
  145. // (development mode) webjars
  146. "/webjars/**",
  147.  
  148. // (development mode) H2 debugging console
  149. "/h2-console/**",
  150.  
  151. // (production mode) static resources
  152. "/frontend-es5/**", "/frontend-es6/**");
  153. }
  154.  
  155. public class getData {
  156. Session session;
  157.  
  158. public getData(){
  159. session = Connection.getConnection();
  160. getDataTable();
  161. }
  162.  
  163. private void getDataTable() {
  164. try {
  165. String query = "SELECT * FROM tableName";
  166. ResultSet rs = session.execute(query);
  167. for (Row row : rs) {
  168. /*Do some stuff here using row*/
  169. }
  170.  
  171. } catch (Exception e) {
  172. e.printStackTrace();
  173. }
  174. }
Add Comment
Please, Sign In to add comment