1 package org.synchronoss.cpo.cassandra;
2
3 /*-
4 * [[
5 * cassandra
6 * ==
7 * Copyright (C) 2003 - 2026 Exaxis LLC, Synchronoss Technologies Inc
8 * ==
9 * This program is free software: you can redistribute it and/or modify
10 * it under the terms of the GNU Lesser General Public License as
11 * published by the Free Software Foundation, either version 3 of the
12 * License, or (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Lesser Public License for more details.
18 *
19 * You should have received a copy of the GNU General Lesser Public
20 * License along with this program. If not, see
21 * <http://www.gnu.org/licenses/lgpl-3.0.html>.
22 * ]]
23 */
24
25 import com.datastax.oss.driver.api.core.CqlSession;
26
27 /**
28 * Represents a Cassandra session
29 *
30 * @author dberry
31 */
32 public class ClusterDataSource {
33 private String keySpace = null;
34 private CqlSession session = null;
35
36 private ClusterDataSource() {}
37
38 /**
39 * Construct a ClusterDataSource
40 *
41 * @param session The cassandra session, already built with the keyspace applied
42 * @param keySpace The keyspace
43 */
44 public ClusterDataSource(CqlSession session, String keySpace) {
45 if (session == null) throw new IllegalArgumentException("CqlSession cannot be null");
46 if (keySpace == null) throw new IllegalArgumentException("KeySpace cannot be null");
47
48 this.session = session;
49 this.keySpace = keySpace;
50 }
51
52 CqlSession getSession() {
53 return session;
54 }
55
56 /**
57 * Gets the keyspace this data source's session is connected to.
58 *
59 * @return the keyspace name
60 */
61 public String getKeySpace() {
62 return keySpace;
63 }
64 }