Merge branch 'master' of https://github.com/sanketmeghani/tutorials into sanketmeghani-master

2016-09-16 18:33:10 +02:00
parent 6355071b53 3d66a5f28a
commit d9b22f816a
47 changed files with 1788 additions and 296 deletions
@@ -7,8 +7,7 @@ import org.junit.Test;
 import java.util.*;
 import java.util.stream.*;

-import static java.util.stream.Collectors.toList;
-import static java.util.stream.Collectors.toSet;
+import static java.util.stream.Collectors.*;
 import static org.hamcrest.CoreMatchers.equalTo;
 import static org.hamcrest.core.IsNot.not;
 import static org.junit.Assert.*;
@@ -22,7 +21,7 @@ public class ArrayListTest {
        List<String> xs = LongStream.range(0, 16)
            .boxed()
            .map(Long::toHexString)
-            .collect(toList());
+            .collect(toCollection(ArrayList::new));
        stringsToSearch = new ArrayList<>(xs);
        stringsToSearch.addAll(xs);
    }
@@ -57,8 +56,8 @@ public class ArrayListTest {
    @Test
    public void givenCollection_whenAddToArrayList_thenIsAdded() {
        List<Long> xs = new ArrayList<>(Arrays.asList(1L, 2L, 3L));
-        Collection<Long> ys = LongStream.range(4, 10).boxed().collect(toList());
-        xs.addAll(0, ys);
+        LongStream.range(4, 10).boxed()
+            .collect(collectingAndThen(toList(), ys -> xs.addAll(0, ys)));

        assertThat(Arrays.asList(4L, 5L, 6L, 7L, 8L, 9L, 1L, 2L, 3L), equalTo(xs));
    }
@@ -92,7 +91,7 @@ public class ArrayListTest {
        List<String> result = stringsToSearch
            .stream()
            .filter(matchingStrings::contains)
-            .collect(toList());
+            .collect(toCollection(ArrayList::new));

        assertEquals(6, result.size());
    }
@@ -107,7 +106,7 @@ public class ArrayListTest {

    @Test
    public void givenIndex_whenRemove_thenCorrectElementRemoved() {
-        List<Integer> xs = IntStream.range(0, 10).boxed().collect(toList());
+        List<Integer> xs = IntStream.range(0, 10).boxed().collect(toCollection(ArrayList::new));
        Collections.reverse(xs);

        xs.remove(0);
@@ -119,7 +118,7 @@ public class ArrayListTest {

    @Test
    public void givenListIterator_whenReverseTraversal_thenRetrieveElementsInOppositeOrder() {
-        List<Integer> xs = IntStream.range(0, 10).boxed().collect(toList());
+        List<Integer> xs = IntStream.range(0, 10).boxed().collect(toCollection(ArrayList::new));
        ListIterator<Integer> it = xs.listIterator(xs.size());
        List<Integer> result = new ArrayList<>(xs.size());
        while (it.hasPrevious()) {
@@ -5,63 +5,59 @@ import java.util.HashSet;

 public class ComplexClass {

-	private ArrayList<?> genericArrayList;
-	private HashSet<Integer> integerHashSet;
+    private ArrayList<?> genericArrayList;
+    private HashSet<Integer> integerHashSet;

-	public ComplexClass(ArrayList<?> genericArrayList,
-			HashSet<Integer> integerHashSet) {
-		super();
-		this.genericArrayList = genericArrayList;
-		this.integerHashSet = integerHashSet;
-	}
+    public ComplexClass(ArrayList<?> genericArrayList, HashSet<Integer> integerHashSet) {
+        super();
+        this.genericArrayList = genericArrayList;
+        this.integerHashSet = integerHashSet;
+    }

-	@Override
-	public int hashCode() {
-		final int prime = 31;
-		int result = 1;
-		result = prime
-				* result
-				+ ((genericArrayList == null) ? 0 : genericArrayList.hashCode());
-		result = prime * result
-				+ ((integerHashSet == null) ? 0 : integerHashSet.hashCode());
-		return result;
-	}
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + ((genericArrayList == null) ? 0 : genericArrayList.hashCode());
+        result = prime * result + ((integerHashSet == null) ? 0 : integerHashSet.hashCode());
+        return result;
+    }

-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj)
-			return true;
-		if (obj == null)
-			return false;
-		if (!(obj instanceof ComplexClass))
-			return false;
-		ComplexClass other = (ComplexClass) obj;
-		if (genericArrayList == null) {
-			if (other.genericArrayList != null)
-				return false;
-		} else if (!genericArrayList.equals(other.genericArrayList))
-			return false;
-		if (integerHashSet == null) {
-			if (other.integerHashSet != null)
-				return false;
-		} else if (!integerHashSet.equals(other.integerHashSet))
-			return false;
-		return true;
-	}
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (!(obj instanceof ComplexClass))
+            return false;
+        ComplexClass other = (ComplexClass) obj;
+        if (genericArrayList == null) {
+            if (other.genericArrayList != null)
+                return false;
+        } else if (!genericArrayList.equals(other.genericArrayList))
+            return false;
+        if (integerHashSet == null) {
+            if (other.integerHashSet != null)
+                return false;
+        } else if (!integerHashSet.equals(other.integerHashSet))
+            return false;
+        return true;
+    }

-	protected ArrayList<?> getGenericArrayList() {
-		return genericArrayList;
-	}
+    protected ArrayList<?> getGenericArrayList() {
+        return genericArrayList;
+    }

-	protected void setGenericArrayList(ArrayList<?> genericArrayList) {
-		this.genericArrayList = genericArrayList;
-	}
+    protected void setGenericArrayList(ArrayList<?> genericArrayList) {
+        this.genericArrayList = genericArrayList;
+    }

-	protected HashSet<Integer> getIntegerHashSet() {
-		return integerHashSet;
-	}
+    protected HashSet<Integer> getIntegerHashSet() {
+        return integerHashSet;
+    }

-	protected void setIntegerHashSet(HashSet<Integer> integerHashSet) {
-		this.integerHashSet = integerHashSet;
-	}
+    protected void setIntegerHashSet(HashSet<Integer> integerHashSet) {
+        this.integerHashSet = integerHashSet;
+    }
 }
@@ -2,53 +2,53 @@ package org.baeldung.equalshashcode.entities;

 public class PrimitiveClass {

-	private boolean primitiveBoolean;
-	private int primitiveInt;
+    private boolean primitiveBoolean;
+    private int primitiveInt;

-	public PrimitiveClass(boolean primitiveBoolean, int primitiveInt) {
-		super();
-		this.primitiveBoolean = primitiveBoolean;
-		this.primitiveInt = primitiveInt;
-	}
+    public PrimitiveClass(boolean primitiveBoolean, int primitiveInt) {
+        super();
+        this.primitiveBoolean = primitiveBoolean;
+        this.primitiveInt = primitiveInt;
+    }

-	protected boolean isPrimitiveBoolean() {
-		return primitiveBoolean;
-	}
+    protected boolean isPrimitiveBoolean() {
+        return primitiveBoolean;
+    }

-	@Override
-	public int hashCode() {
-		final int prime = 31;
-		int result = 1;
-		result = prime * result + (primitiveBoolean ? 1231 : 1237);
-		result = prime * result + primitiveInt;
-		return result;
-	}
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = prime * result + (primitiveBoolean ? 1231 : 1237);
+        result = prime * result + primitiveInt;
+        return result;
+    }

-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj)
-			return true;
-		if (obj == null)
-			return false;
-		if (getClass() != obj.getClass())
-			return false;
-		PrimitiveClass other = (PrimitiveClass) obj;
-		if (primitiveBoolean != other.primitiveBoolean)
-			return false;
-		if (primitiveInt != other.primitiveInt)
-			return false;
-		return true;
-	}
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        PrimitiveClass other = (PrimitiveClass) obj;
+        if (primitiveBoolean != other.primitiveBoolean)
+            return false;
+        if (primitiveInt != other.primitiveInt)
+            return false;
+        return true;
+    }

-	protected void setPrimitiveBoolean(boolean primitiveBoolean) {
-		this.primitiveBoolean = primitiveBoolean;
-	}
+    protected void setPrimitiveBoolean(boolean primitiveBoolean) {
+        this.primitiveBoolean = primitiveBoolean;
+    }

-	protected int getPrimitiveInt() {
-		return primitiveInt;
-	}
+    protected int getPrimitiveInt() {
+        return primitiveInt;
+    }

-	protected void setPrimitiveInt(int primitiveInt) {
-		this.primitiveInt = primitiveInt;
-	}
+    protected void setPrimitiveInt(int primitiveInt) {
+        this.primitiveInt = primitiveInt;
+    }
 }
@@ -1,62 +1,60 @@
 package org.baeldung.equalshashcode.entities;

 public class Rectangle extends Shape {
-	private double width;
-	private double length;
+    private double width;
+    private double length;

-	public Rectangle(double width, double length) {
-		this.width = width;
-		this.length = length;
-	}
+    public Rectangle(double width, double length) {
+        this.width = width;
+        this.length = length;
+    }

-	@Override
-	public double area() {
-		// A = w * l
-		return width * length;
-	}
+    @Override
+    public double area() {
+        // A = w * l
+        return width * length;
+    }

-	@Override
-	public double perimeter() {
-		// P = 2(w + l)
-		return 2 * (width + length);
-	}
+    @Override
+    public double perimeter() {
+        // P = 2(w + l)
+        return 2 * (width + length);
+    }

-	@Override
-	public int hashCode() {
-		final int prime = 31;
-		int result = 1;
-		long temp;
-		temp = Double.doubleToLongBits(length);
-		result = prime * result + (int) (temp ^ (temp >>> 32));
-		temp = Double.doubleToLongBits(width);
-		result = prime * result + (int) (temp ^ (temp >>> 32));
-		return result;
-	}
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        long temp;
+        temp = Double.doubleToLongBits(length);
+        result = prime * result + (int) (temp ^ (temp >>> 32));
+        temp = Double.doubleToLongBits(width);
+        result = prime * result + (int) (temp ^ (temp >>> 32));
+        return result;
+    }

-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj)
-			return true;
-		if (obj == null)
-			return false;
-		if (getClass() != obj.getClass())
-			return false;
-		Rectangle other = (Rectangle) obj;
-		if (Double.doubleToLongBits(length) != Double
-				.doubleToLongBits(other.length))
-			return false;
-		if (Double.doubleToLongBits(width) != Double
-				.doubleToLongBits(other.width))
-			return false;
-		return true;
-	}
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj)
+            return true;
+        if (obj == null)
+            return false;
+        if (getClass() != obj.getClass())
+            return false;
+        Rectangle other = (Rectangle) obj;
+        if (Double.doubleToLongBits(length) != Double.doubleToLongBits(other.length))
+            return false;
+        if (Double.doubleToLongBits(width) != Double.doubleToLongBits(other.width))
+            return false;
+        return true;
+    }

-	protected double getWidth() {
-		return width;
-	}
+    protected double getWidth() {
+        return width;
+    }

-	protected double getLength() {
-		return length;
-	}
+    protected double getLength() {
+        return length;
+    }

 }
@@ -1,7 +1,7 @@
 package org.baeldung.equalshashcode.entities;

 public abstract class Shape {
-	public abstract double area();
+    public abstract double area();

-	public abstract double perimeter();
+    public abstract double perimeter();
 }
@@ -4,44 +4,55 @@ import java.awt.Color;

 public class Square extends Rectangle {

-	Color color;
+    Color color;

-	public Square(double width, Color color) {
-		super(width, width);
-		this.color = color;
-	}
+    public Square(double width, Color color) {
+        super(width, width);
+        this.color = color;
+    }

-	@Override
-	public int hashCode() {
-		final int prime = 31;
-		int result = super.hashCode();
-		result = prime * result + ((color == null) ? 0 : color.hashCode());
-		return result;
-	}
+    /* (non-Javadoc)
+     * @see java.lang.Object#hashCode()
+     */
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = super.hashCode();
+        result = prime * result + ((color == null) ? 0 : color.hashCode());
+        return result;
+    }

-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj)
-			return true;
-		if (!super.equals(obj))
-			return false;
-		if (getClass() != obj.getClass())
-			return false;
-		Square other = (Square) obj;
-		if (color == null) {
-			if (other.color != null)
-				return false;
-		} else if (!color.equals(other.color))
-			return false;
-		return true;
-	}
+    /* (non-Javadoc)
+     * @see java.lang.Object#equals(java.lang.Object)
+     */
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (!super.equals(obj)) {
+            return false;
+        }
+        if (!(obj instanceof Square)) {
+            return false;
+        }
+        Square other = (Square) obj;
+        if (color == null) {
+            if (other.color != null) {
+                return false;
+            }
+        } else if (!color.equals(other.color)) {
+            return false;
+        }
+        return true;
+    }

-	protected Color getColor() {
-		return color;
-	}
+    protected Color getColor() {
+        return color;
+    }

-	protected void setColor(Color color) {
-		this.color = color;
-	}
+    protected void setColor(Color color) {
+        this.color = color;
+    }

 }
@@ -8,32 +8,27 @@ import org.junit.Test;

 public class ComplexClassTest {

-	@Test
-	public void testEqualsAndHashcodes() {
-		
-		ArrayList<String> strArrayList = new ArrayList<String>();
-		strArrayList.add("abc");
-		strArrayList.add("def");
-		ComplexClass aObject = new ComplexClass(strArrayList, new HashSet<Integer>(45,67));
-		ComplexClass bObject = new ComplexClass(strArrayList, new HashSet<Integer>(45,67));
-		ComplexClass cObject = new ComplexClass(strArrayList, new HashSet<Integer>(45,67));
-		
-		ArrayList<String> strArrayListD = new ArrayList<String>();
-		strArrayListD.add("lmn");
-		strArrayListD.add("pqr");
-		ComplexClass dObject = new ComplexClass(strArrayListD, new HashSet<Integer>(45,67));
-		
-		// equals()
-		Assert.assertTrue(aObject.equals(aObject));
-		Assert.assertTrue(aObject.equals(bObject) && bObject.equals(aObject));
-		Assert.assertTrue(aObject.equals(bObject));
-		Assert.assertTrue(bObject.equals(cObject));
-		Assert.assertTrue(aObject.equals(cObject));
-		// hashCode()
-		Assert.assertTrue(aObject.hashCode() == bObject.hashCode());
-		// non-equal objects are not equals() and have different hashCode()
-		Assert.assertFalse(aObject.equals(dObject));
-		Assert.assertFalse(aObject.hashCode() == dObject.hashCode());
-	}
+    @Test
+    public void testEqualsAndHashcodes() {
+
+        ArrayList<String> strArrayList = new ArrayList<String>();
+        strArrayList.add("abc");
+        strArrayList.add("def");
+        ComplexClass aObject = new ComplexClass(strArrayList, new HashSet<Integer>(45, 67));
+        ComplexClass bObject = new ComplexClass(strArrayList, new HashSet<Integer>(45, 67));
+
+        ArrayList<String> strArrayListD = new ArrayList<String>();
+        strArrayListD.add("lmn");
+        strArrayListD.add("pqr");
+        ComplexClass dObject = new ComplexClass(strArrayListD, new HashSet<Integer>(45, 67));
+
+        // equals()
+        Assert.assertTrue(aObject.equals(bObject) && bObject.equals(aObject));
+        // hashCode()
+        Assert.assertTrue(aObject.hashCode() == bObject.hashCode());
+        // non-equal objects are not equals() and have different hashCode()
+        Assert.assertFalse(aObject.equals(dObject));
+        Assert.assertFalse(aObject.hashCode() == dObject.hashCode());
+    }

 }
@@ -5,25 +5,20 @@ import org.junit.Test;

 public class PrimitiveClassTest {

-	@Test
-	public void testTwoEqualsObjects() {
+    @Test
+    public void testTwoEqualsObjects() {

-		PrimitiveClass aObject = new PrimitiveClass(false, 2);
-		PrimitiveClass bObject = new PrimitiveClass(false, 2);
-		PrimitiveClass cObject = new PrimitiveClass(false, 2);
-		PrimitiveClass dObject = new PrimitiveClass(true, 2);
+        PrimitiveClass aObject = new PrimitiveClass(false, 2);
+        PrimitiveClass bObject = new PrimitiveClass(false, 2);
+        PrimitiveClass dObject = new PrimitiveClass(true, 2);

-		// equals()
-		Assert.assertTrue(aObject.equals(aObject));
-		Assert.assertTrue(aObject.equals(bObject) && bObject.equals(aObject));
-		Assert.assertTrue(aObject.equals(bObject));
-		Assert.assertTrue(bObject.equals(cObject));
-		Assert.assertTrue(aObject.equals(cObject));
-		// hashCode()
-		Assert.assertTrue(aObject.hashCode() == bObject.hashCode());
-		// non-equal objects are not equals() and have different hashCode()
-		Assert.assertFalse(aObject.equals(dObject));
-		Assert.assertFalse(aObject.hashCode() == dObject.hashCode());
-	}
+        // equals()
+        Assert.assertTrue(aObject.equals(bObject) && bObject.equals(aObject));
+        // hashCode()
+        Assert.assertTrue(aObject.hashCode() == bObject.hashCode());
+        // non-equal objects are not equals() and have different hashCode()
+        Assert.assertFalse(aObject.equals(dObject));
+        Assert.assertFalse(aObject.hashCode() == dObject.hashCode());
+    }

 }
@@ -7,26 +7,21 @@ import org.junit.Test;

 public class SquareClassTest {

-	@Test
-	public void testEqualsAndHashcodes() {
-		
-		Square aObject = new Square(10, Color.BLUE);
-		Square bObject = new Square(10, Color.BLUE);
-		Square cObject = new Square(10, Color.BLUE);
-		
-		Square dObject = new Square(20, Color.BLUE);
-		
-		// equals()
-		Assert.assertTrue(aObject.equals(aObject));
-		Assert.assertTrue(aObject.equals(bObject) && bObject.equals(aObject));
-		Assert.assertTrue(aObject.equals(bObject));
-		Assert.assertTrue(bObject.equals(cObject));
-		Assert.assertTrue(aObject.equals(cObject));		
-		// hashCode()
-		Assert.assertTrue(aObject.hashCode() == bObject.hashCode());		
-		// non-equal objects are not equals() and have different hashCode()
-		Assert.assertFalse(aObject.equals(dObject));
-		Assert.assertFalse(aObject.hashCode() == dObject.hashCode());
-	}
+    @Test
+    public void testEqualsAndHashcodes() {
+
+        Square aObject = new Square(10, Color.BLUE);
+        Square bObject = new Square(10, Color.BLUE);
+
+        Square dObject = new Square(20, Color.BLUE);
+
+        // equals()
+        Assert.assertTrue(aObject.equals(bObject) && bObject.equals(aObject));
+        // hashCode()
+        Assert.assertTrue(aObject.hashCode() == bObject.hashCode());
+        // non-equal objects are not equals() and have different hashCode()
+        Assert.assertFalse(aObject.equals(dObject));
+        Assert.assertFalse(aObject.hashCode() == dObject.hashCode());
+    }

 }
@@ -0,0 +1,8 @@
+CREATE TABLE IF NOT EXISTS `department` (
+
+`id` int NOT NULL AUTO_INCREMENT PRIMARY KEY,
+`name` varchar(20)
+
+)ENGINE=InnoDB DEFAULT CHARSET=UTF8; 
+
+ALTER TABLE `employee` ADD `dept_id` int AFTER `email`;
@@ -23,6 +23,7 @@
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.5.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
@@ -0,0 +1,102 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.baeldung</groupId>
+    <artifactId>cassandra-java-client</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+    
+      <name>cassandra-java-client</name>
+      
+      <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        
+        <!-- logging -->
+        <org.slf4j.version>1.7.21</org.slf4j.version>
+        <logback.version>1.1.7</logback.version>
+        
+        <!-- testing -->
+        <org.hamcrest.version>1.3</org.hamcrest.version>
+        <junit.version>4.12</junit.version>
+        <mockito.version>1.10.19</mockito.version>
+        <testng.version>6.8</testng.version>
+        <assertj.version>3.5.1</assertj.version>
+        
+        <!-- maven plugins -->
+        <maven-compiler-plugin.version>3.5.1</maven-compiler-plugin.version>
+        
+        <!-- Cassandra -->
+        <cassandra-driver-core.version>3.1.0</cassandra-driver-core.version>
+      </properties>
+  
+      <dependencies>
+          <!-- Cassandra -->
+          <dependency>
+            <groupId>com.datastax.cassandra</groupId>
+            <artifactId>cassandra-driver-core</artifactId>
+            <version>${cassandra-driver-core.version}</version>
+            <optional>true</optional>
+        </dependency>
+        
+        <!-- https://mvnrepository.com/artifact/org.cassandraunit/cassandra-unit -->
+        <dependency>
+            <groupId>org.cassandraunit</groupId>
+            <artifactId>cassandra-unit</artifactId>
+            <version>3.0.0.1</version>
+        </dependency>
+        
+        <!-- This guava version is required for cassandra-unit 3.0.0.1 -->
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>19.0</version>
+        </dependency>
+        
+          <!-- logging -->
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${org.slf4j.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>${logback.version}</version>
+            <!-- <scope>runtime</scope> -->
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>jcl-over-slf4j</artifactId>
+            <version>${org.slf4j.version}</version>
+            <!-- <scope>runtime</scope> --> <!-- some spring dependencies need to compile against jcl -->
+        </dependency>
+        <dependency> <!-- needed to bridge to slf4j for projects that use the log4j APIs directly -->
+            <groupId>org.slf4j</groupId>
+            <artifactId>log4j-over-slf4j</artifactId>
+            <version>${org.slf4j.version}</version>
+        </dependency>
+        
+        <dependency>
+              <groupId>junit</groupId>
+              <artifactId>junit</artifactId>
+              <version>${junit.version}</version>
+              <scope>test</scope>
+        </dependency>
+      </dependencies>
+      
+      <build>
+        <finalName>java-cassandra</finalName>
+
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${maven-compiler-plugin.version}</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+
+    </build>
+</project>
@@ -0,0 +1,44 @@
+package com.baeldung.cassandra.java.client;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.baeldung.cassandra.java.client.domain.Book;
+import com.baeldung.cassandra.java.client.repository.BookRepository;
+import com.baeldung.cassandra.java.client.repository.KeyspaceRepository;
+import com.datastax.driver.core.Session;
+import com.datastax.driver.core.utils.UUIDs;
+
+public class CassandraClient {
+    private static final Logger LOG = LoggerFactory.getLogger(CassandraClient.class);
+    
+    public static void main(String args[]) {
+        CassandraConnector connector = new CassandraConnector();
+        connector.connect("127.0.0.1", null);
+        Session session = connector.getSession();
+        
+        KeyspaceRepository sr = new KeyspaceRepository(session);
+        sr.createKeyspace("library", "SimpleStrategy", 1);
+        sr.useKeyspace("library");
+
+        BookRepository br = new BookRepository(session);
+        br.createTable();
+        br.alterTablebooks("publisher", "text");
+        
+        br.createTableBooksByTitle();
+        
+        Book book = new Book(UUIDs.timeBased(), "Effective Java", "Joshua Bloch", "Programming");
+        br.insertBookBatch(book);
+        
+        br.selectAll().forEach(o -> LOG.info("Title in books: " + o.getTitle()));
+        br.selectAllBookByTitle().forEach(o -> LOG.info("Title in booksByTitle: " + o.getTitle()));
+        
+        br.deletebookByTitle("Effective Java");
+        br.deleteTable("books");
+        br.deleteTable("booksByTitle");
+
+        sr.deleteKeyspace("library");
+        
+        connector.close();
+    }
+}
@@ -0,0 +1,51 @@
+package com.baeldung.cassandra.java.client;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.datastax.driver.core.Cluster;
+import com.datastax.driver.core.Cluster.Builder;
+import com.datastax.driver.core.Host;
+import com.datastax.driver.core.Metadata;
+import com.datastax.driver.core.Session;
+
+/**
+ * 
+ * This is an implementation of a simple Java client.
+ *
+ */
+public class CassandraConnector {
+    private static final Logger LOG = LoggerFactory.getLogger(CassandraConnector.class);
+
+    private Cluster cluster;
+
+    private Session session;
+
+    public void connect(final String node, final Integer port) {
+
+        Builder b = Cluster.builder().addContactPoint(node);
+
+        if (port != null) {
+            b.withPort(port);
+        }
+        cluster = b.build();
+
+        Metadata metadata = cluster.getMetadata();
+        LOG.info("Cluster name: " + metadata.getClusterName());
+
+        for (Host host : metadata.getAllHosts()) {
+            LOG.info("Datacenter: " + host.getDatacenter() + " Host: " + host.getAddress() + " Rack: " + host.getRack());
+        }
+
+        session = cluster.connect();
+    }
+
+    public Session getSession() {
+        return this.session;
+    }
+
+    public void close() {
+        session.close();
+        cluster.close();
+    }
+}
@@ -0,0 +1,66 @@
+package com.baeldung.cassandra.java.client.domain;
+
+import java.util.UUID;
+
+public class Book {
+
+    private UUID id;
+
+    private String title;
+
+    private String author;
+
+    private String subject;
+
+    private String publisher;
+
+    Book() {
+    }
+    
+    public Book(UUID id, String title, String author, String subject) {
+        this.id = id;
+        this.title = title;
+        this.author = author;
+        this.subject = subject;
+    }
+    
+    public UUID getId() {
+        return id;
+    }
+
+    public void setId(UUID id) {
+        this.id = id;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getAuthor() {
+        return author;
+    }
+
+    public void setAuthor(String author) {
+        this.author = author;
+    }
+
+    public String getSubject() {
+        return subject;
+    }
+
+    public void setSubject(String subject) {
+        this.subject = subject;
+    }
+
+    public String getPublisher() {
+        return publisher;
+    }
+
+    public void setPublisher(String publisher) {
+        this.publisher = publisher;
+    }
+}
@@ -0,0 +1,177 @@
+package com.baeldung.cassandra.java.client.repository;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import com.baeldung.cassandra.java.client.domain.Book;
+import com.datastax.driver.core.ResultSet;
+import com.datastax.driver.core.Row;
+import com.datastax.driver.core.Session;
+
+public class BookRepository {
+
+    private static final String TABLE_NAME = "books";
+    
+    private static final String TABLE_NAME_BY_TITLE = TABLE_NAME + "ByTitle";
+
+    private Session session;
+
+    public BookRepository(Session session) {
+        this.session = session;
+    }
+
+    /**
+     * Creates the books table.
+     */
+    public void createTable() {
+        StringBuilder sb = new StringBuilder("CREATE TABLE IF NOT EXISTS ").append(TABLE_NAME).append("(").append("id uuid PRIMARY KEY, ").append("title text,").append("author text,").append("subject text);");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+    
+    /**
+     * Creates the books table.
+     */
+    public void createTableBooksByTitle() {
+        StringBuilder sb = new StringBuilder("CREATE TABLE IF NOT EXISTS ").append(TABLE_NAME_BY_TITLE).append("(").append("id uuid, ").append("title text,").append("PRIMARY KEY (title, id));");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+
+    /**
+     * Alters the table books and adds an extra column.
+     */
+    public void alterTablebooks(String columnName, String columnType) {
+        StringBuilder sb = new StringBuilder("ALTER TABLE ").append(TABLE_NAME).append(" ADD ").append(columnName).append(" ").append(columnType).append(";");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+
+    /**
+     * Insert a row in the table books. 
+     * 
+     * @param book
+     */
+    public void insertbook(Book book) {
+        StringBuilder sb = new StringBuilder("INSERT INTO ").append(TABLE_NAME).append("(id, title, author, subject) ").append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("', '").append(book.getAuthor()).append("', '")
+                .append(book.getSubject()).append("');");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+    
+    /**
+     * Insert a row in the table booksByTitle.
+     * @param book
+     */
+    public void insertbookByTitle(Book book) {
+        StringBuilder sb = new StringBuilder("INSERT INTO ").append(TABLE_NAME_BY_TITLE).append("(id, title) ").append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("');");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+    
+    /**
+     * Insert a book into two identical tables using a batch query.
+     * 
+     * @param book
+     */
+    public void insertBookBatch(Book book) {
+        StringBuilder sb = new StringBuilder("BEGIN BATCH ")
+                .append("INSERT INTO ").append(TABLE_NAME).append("(id, title, author, subject) ")
+                .append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("', '").append(book.getAuthor()).append("', '")
+                .append(book.getSubject()).append("');")
+                .append("INSERT INTO ").append(TABLE_NAME_BY_TITLE).append("(id, title) ")
+                .append("VALUES (").append(book.getId()).append(", '").append(book.getTitle()).append("');")
+                .append("APPLY BATCH;");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+
+    /**
+     * Select book by id.
+     * 
+     * @return
+     */
+    public Book selectByTitle(String title) {
+        StringBuilder sb = new StringBuilder("SELECT * FROM ").append(TABLE_NAME_BY_TITLE).append(" WHERE title = '").append(title).append("';");
+
+        final String query = sb.toString();
+        
+        ResultSet rs = session.execute(query);
+
+        List<Book> books = new ArrayList<Book>();
+
+        for (Row r : rs) {
+            Book s = new Book(r.getUUID("id"), r.getString("title"), null, null);
+            books.add(s);
+        }
+
+        return books.get(0);
+    }
+
+    /**
+     * Select all books from books
+     * 
+     * @return
+     */
+    public List<Book> selectAll() {
+        StringBuilder sb = new StringBuilder("SELECT * FROM ").append(TABLE_NAME);
+
+        final String query = sb.toString();
+        ResultSet rs = session.execute(query);
+
+        List<Book> books = new ArrayList<Book>();
+
+        for (Row r : rs) {
+            Book book = new Book(r.getUUID("id"), r.getString("title"), r.getString("author"), r.getString("subject"));
+            books.add(book);
+        }
+        return books;
+    }
+    
+    /**
+     * Select all books from booksByTitle
+     * @return
+     */
+    public List<Book> selectAllBookByTitle() {
+        StringBuilder sb = new StringBuilder("SELECT * FROM ").append(TABLE_NAME_BY_TITLE);
+
+        final String query = sb.toString();
+        ResultSet rs = session.execute(query);
+
+        List<Book> books = new ArrayList<Book>();
+
+        for (Row r : rs) {
+            Book book = new Book(r.getUUID("id"), r.getString("title"), null, null);
+            books.add(book);
+        }
+        return books;
+    }
+
+    /**
+     * Delete a book by title.
+     */
+    public void deletebookByTitle(String title) {
+        StringBuilder sb = new StringBuilder("DELETE FROM ").append(TABLE_NAME_BY_TITLE).append(" WHERE title = '").append(title).append("';");
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+
+    /**
+     * Delete table.
+     * 
+     * @param tableName the name of the table to delete.
+     */
+    public void deleteTable(String tableName) {
+        StringBuilder sb = new StringBuilder("DROP TABLE IF EXISTS ").append(tableName);
+
+        final String query = sb.toString();
+        session.execute(query);
+    }
+}
@@ -0,0 +1,49 @@
+package com.baeldung.cassandra.java.client.repository;
+
+import com.datastax.driver.core.Session;
+
+/**
+ * Repository to handle the Cassandra schema.
+ *
+ */
+public class KeyspaceRepository {
+    private Session session;
+
+    public KeyspaceRepository(Session session) {
+        this.session = session;
+    }
+
+    /**
+     * Method used to create any keyspace - schema.
+     * 
+     * @param schemaName the name of the schema.
+     * @param replicatioonStrategy the replication strategy.
+     * @param numberOfReplicas the number of replicas.
+     * 
+     */
+    public void createKeyspace(String keyspaceName, String replicatioonStrategy, int numberOfReplicas) {
+        StringBuilder sb = new StringBuilder("CREATE KEYSPACE IF NOT EXISTS ").append(keyspaceName).append(" WITH replication = {").append("'class':'").append(replicatioonStrategy).append("','replication_factor':").append(numberOfReplicas).append("};");
+
+        final String query = sb.toString();
+
+        session.execute(query);
+    }
+
+    public void useKeyspace(String keyspace) {
+        session.execute("USE " + keyspace);
+    }
+
+    /**
+     * Method used to delete the specified schema.
+     * It results in the immediate, irreversable removal of the keyspace, including all tables and data contained in the keyspace.
+     * 
+     * @param schemaName the name of the keyspace to delete.
+     */
+    public void deleteKeyspace(String keyspaceName) {
+        StringBuilder sb = new StringBuilder("DROP KEYSPACE ").append(keyspaceName);
+
+        final String query = sb.toString();
+
+        session.execute(query);
+    }
+}
@@ -0,0 +1,174 @@
+package com.baeldung.cassandra.java.client.repository;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.apache.cassandra.exceptions.ConfigurationException;
+import org.apache.thrift.transport.TTransportException;
+import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import com.baeldung.cassandra.java.client.CassandraConnector;
+import com.baeldung.cassandra.java.client.domain.Book;
+import com.datastax.driver.core.ResultSet;
+import com.datastax.driver.core.Session;
+import com.datastax.driver.core.exceptions.InvalidQueryException;
+import com.datastax.driver.core.utils.UUIDs;
+
+public class BookRepositoryIntegrationTest {
+
+    private KeyspaceRepository schemaRepository;
+
+    private BookRepository bookRepository;
+
+    private Session session;
+
+    final String KEYSPACE_NAME = "testLibrary";
+    final String BOOKS = "books";
+    final String BOOKS_BY_TITLE = "booksByTitle";
+
+    @BeforeClass
+    public static void init() throws ConfigurationException, TTransportException, IOException, InterruptedException {
+        // Start an embedded Cassandra Server
+        EmbeddedCassandraServerHelper.startEmbeddedCassandra(20000L);
+    }
+
+    @Before
+    public void connect() {
+        CassandraConnector client = new CassandraConnector();
+        client.connect("127.0.0.1", 9142);
+        this.session = client.getSession();
+        schemaRepository = new KeyspaceRepository(session);
+        schemaRepository.createKeyspace(KEYSPACE_NAME, "SimpleStrategy", 1);
+        schemaRepository.useKeyspace(KEYSPACE_NAME);
+        bookRepository = new BookRepository(session);
+    }
+
+    @Test
+    public void whenCreatingATable_thenCreatedCorrectly() {
+        bookRepository.deleteTable(BOOKS);
+        bookRepository.createTable();
+
+        ResultSet result = session.execute("SELECT * FROM " + KEYSPACE_NAME + "." + BOOKS + ";");
+
+        // Collect all the column names in one list.
+        List<String> columnNames = result.getColumnDefinitions().asList().stream().map(cl -> cl.getName()).collect(Collectors.toList());
+        assertEquals(columnNames.size(), 4);
+        assertTrue(columnNames.contains("id"));
+        assertTrue(columnNames.contains("title"));
+        assertTrue(columnNames.contains("author"));
+        assertTrue(columnNames.contains("subject"));
+    }
+
+    @Test
+    public void whenAlteringTable_thenAddedColumnExists() {
+        bookRepository.deleteTable(BOOKS);
+        bookRepository.createTable();
+
+        bookRepository.alterTablebooks("publisher", "text");
+
+        ResultSet result = session.execute("SELECT * FROM " + KEYSPACE_NAME + "." + BOOKS + ";");
+
+        boolean columnExists = result.getColumnDefinitions().asList().stream().anyMatch(cl -> cl.getName().equals("publisher"));
+        assertTrue(columnExists);
+    }
+
+    @Test
+    public void whenAddingANewBook_thenBookExists() {
+        bookRepository.deleteTable(BOOKS_BY_TITLE);
+        bookRepository.createTableBooksByTitle();
+
+        String title = "Effective Java";
+        String author = "Joshua Bloch";
+        Book book = new Book(UUIDs.timeBased(), title, author, "Programming");
+        bookRepository.insertbookByTitle(book);
+
+        Book savedBook = bookRepository.selectByTitle(title);
+        assertEquals(book.getTitle(), savedBook.getTitle());
+    }
+
+    @Test
+    public void whenAddingANewBookBatch_ThenBookAddedInAllTables() {
+        // Create table books
+        bookRepository.deleteTable(BOOKS);
+        bookRepository.createTable();
+
+        // Create table booksByTitle
+        bookRepository.deleteTable(BOOKS_BY_TITLE);
+        bookRepository.createTableBooksByTitle();
+
+        String title = "Effective Java";
+        String author = "Joshua Bloch";
+        Book book = new Book(UUIDs.timeBased(), title, author, "Programming");
+        bookRepository.insertBookBatch(book);
+
+        List<Book> books = bookRepository.selectAll();
+
+        assertEquals(1, books.size());
+        assertTrue(books.stream().anyMatch(b -> b.getTitle().equals("Effective Java")));
+
+        List<Book> booksByTitle = bookRepository.selectAllBookByTitle();
+
+        assertEquals(1, booksByTitle.size());
+        assertTrue(booksByTitle.stream().anyMatch(b -> b.getTitle().equals("Effective Java")));
+    }
+
+    @Test
+    public void whenSelectingAll_thenReturnAllRecords() {
+        bookRepository.deleteTable(BOOKS);
+        bookRepository.createTable();
+
+        Book book = new Book(UUIDs.timeBased(), "Effective Java", "Joshua Bloch", "Programming");
+        bookRepository.insertbook(book);
+
+        book = new Book(UUIDs.timeBased(), "Clean Code", "Robert C. Martin", "Programming");
+        bookRepository.insertbook(book);
+
+        List<Book> books = bookRepository.selectAll();
+
+        assertEquals(2, books.size());
+        assertTrue(books.stream().anyMatch(b -> b.getTitle().equals("Effective Java")));
+        assertTrue(books.stream().anyMatch(b -> b.getTitle().equals("Clean Code")));
+    }
+
+    @Test
+    public void whenDeletingABookByTitle_thenBookIsDeleted() {
+        bookRepository.deleteTable(BOOKS_BY_TITLE);
+        bookRepository.createTableBooksByTitle();
+
+        Book book = new Book(UUIDs.timeBased(), "Effective Java", "Joshua Bloch", "Programming");
+        bookRepository.insertbookByTitle(book);
+
+        book = new Book(UUIDs.timeBased(), "Clean Code", "Robert C. Martin", "Programming");
+        bookRepository.insertbookByTitle(book);
+
+        bookRepository.deletebookByTitle("Clean Code");
+
+        List<Book> books = bookRepository.selectAllBookByTitle();
+        assertEquals(1, books.size());
+        assertTrue(books.stream().anyMatch(b -> b.getTitle().equals("Effective Java")));
+        assertFalse(books.stream().anyMatch(b -> b.getTitle().equals("Clean Code")));
+
+    }
+
+    @Test(expected = InvalidQueryException.class)
+    public void whenDeletingATable_thenUnconfiguredTable() {
+        bookRepository.createTable();
+        bookRepository.deleteTable(BOOKS);
+
+        session.execute("SELECT * FROM " + KEYSPACE_NAME + "." + BOOKS + ";");
+    }
+
+    @AfterClass
+    public static void cleanup() {
+        EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
+    }
+}
@@ -0,0 +1,77 @@
+package com.baeldung.cassandra.java.client.repository;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.apache.cassandra.exceptions.ConfigurationException;
+import org.apache.thrift.transport.TTransportException;
+import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.FixMethodOrder;
+import org.junit.Test;
+import org.junit.runners.MethodSorters;
+
+import com.baeldung.cassandra.java.client.CassandraConnector;
+import com.datastax.driver.core.ResultSet;
+import com.datastax.driver.core.Session;
+
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class KeyspaceRepositoryIntegrationTest {
+
+    private KeyspaceRepository schemaRepository;
+
+    private Session session;
+
+    @BeforeClass
+    public static void init() throws ConfigurationException, TTransportException, IOException, InterruptedException {
+        // Start an embedded Cassandra Server
+        EmbeddedCassandraServerHelper.startEmbeddedCassandra(20000L);
+    }
+
+    @Before
+    public void connect() {
+        CassandraConnector client = new CassandraConnector();
+        client.connect("127.0.0.1", 9142);
+        this.session = client.getSession();
+        schemaRepository = new KeyspaceRepository(session);
+    }
+
+    @Test
+    public void whenCreatingAKeyspace_thenCreated() {
+        String keyspaceName = "testBaeldungKeyspace";
+        schemaRepository.createKeyspace(keyspaceName, "SimpleStrategy", 1);
+
+        // ResultSet result = session.execute("SELECT * FROM system_schema.keyspaces WHERE keyspace_name = 'testBaeldungKeyspace';");
+
+        ResultSet result = session.execute("SELECT * FROM system_schema.keyspaces;");
+
+        // Check if the Keyspace exists in the returned keyspaces.
+        List<String> matchedKeyspaces = result.all().stream().filter(r -> r.getString(0).equals(keyspaceName.toLowerCase())).map(r -> r.getString(0)).collect(Collectors.toList());
+        assertEquals(matchedKeyspaces.size(), 1);
+        assertTrue(matchedKeyspaces.get(0).equals(keyspaceName.toLowerCase()));
+    }
+
+    @Test
+    public void whenDeletingAKeyspace_thenDoesNotExist() {
+        String keyspaceName = "testBaeldungKeyspace";
+
+        // schemaRepository.createKeyspace(keyspaceName, "SimpleStrategy", 1);
+        schemaRepository.deleteKeyspace(keyspaceName);
+
+        ResultSet result = session.execute("SELECT * FROM system_schema.keyspaces;");
+        boolean isKeyspaceCreated = result.all().stream().anyMatch(r -> r.getString(0).equals(keyspaceName.toLowerCase()));
+        assertFalse(isKeyspaceCreated);
+    }
+
+    @AfterClass
+    public static void cleanup() {
+        EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
+    }
+}
@@ -129,7 +129,7 @@
        <module>redis</module>

        <module>xstream</module>
-
+        <module>java-cassandra</module>
    </modules>

 </project>
@@ -0,0 +1,8 @@
+package org.baeldung.persistence.multiple.dao.user;
+
+import org.baeldung.persistence.multiple.model.user.Possession;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface PossessionRepository extends JpaRepository<Possession, Long> {
+
+}
@@ -0,0 +1,86 @@
+package org.baeldung.persistence.multiple.model.user;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table(schema = "spring_jpa_user")
+public class Possession {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.AUTO)
+    private long id;
+
+    private String name;
+
+    public Possession() {
+        super();
+    }
+
+    public Possession(final String name) {
+        super();
+
+        this.name = name;
+    }
+
+    public long getId() {
+        return id;
+    }
+
+    public void setId(final int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(final String name) {
+        this.name = name;
+    }
+
+    @Override
+    public int hashCode() {
+        final int prime = 31;
+        int result = 1;
+        result = (prime * result) + (int) (id ^ (id >>> 32));
+        result = (prime * result) + ((name == null) ? 0 : name.hashCode());
+        return result;
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj == null) {
+            return false;
+        }
+        if (getClass() != obj.getClass()) {
+            return false;
+        }
+        final Possession other = (Possession) obj;
+        if (id != other.id) {
+            return false;
+        }
+        if (name == null) {
+            if (other.name != null) {
+                return false;
+            }
+        } else if (!name.equals(other.name)) {
+            return false;
+        }
+        return true;
+    }
+
+    @Override
+    public String toString() {
+        final StringBuilder builder = new StringBuilder();
+        builder.append("Possesion [id=").append(id).append(", name=").append(name).append("]");
+        return builder.toString();
+    }
+
+}
@@ -1,10 +1,13 @@
 package org.baeldung.persistence.multiple.model.user;

+import java.util.List;
+
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.GeneratedValue;
 import javax.persistence.GenerationType;
 import javax.persistence.Id;
+import javax.persistence.OneToMany;
 import javax.persistence.Table;

@Entity
@@ -22,6 +25,9 @@ public class User {

    private int age;

+    @OneToMany
+    List<Possession> possessionList;
+
    public User() {
        super();
    }
@@ -58,6 +64,14 @@ public class User {
        this.age = age;
    }

+    public List<Possession> getPossessionList() {
+        return possessionList;
+    }
+
+    public void setPossessionList(List<Possession> possessionList) {
+        this.possessionList = possessionList;
+    }
+
    @Override
    public String toString() {
        final StringBuilder builder = new StringBuilder();
@@ -1,14 +1,18 @@
 package org.baeldung.persistence.service;

 import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;

+import java.util.Arrays;
+
 import org.baeldung.config.ProductConfig;
 import org.baeldung.config.UserConfig;
 import org.baeldung.persistence.multiple.dao.product.ProductRepository;
+import org.baeldung.persistence.multiple.dao.user.PossessionRepository;
 import org.baeldung.persistence.multiple.dao.user.UserRepository;
 import org.baeldung.persistence.multiple.model.product.Product;
+import org.baeldung.persistence.multiple.model.user.Possession;
 import org.baeldung.persistence.multiple.model.user.User;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -16,15 +20,20 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 import org.springframework.transaction.annotation.Transactional;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = { UserConfig.class, ProductConfig.class })
+@EnableTransactionManagement
 public class JpaMultipleDBIntegrationTest {

    @Autowired
    private UserRepository userRepository;

+    @Autowired
+    private PossessionRepository possessionRepository;
+
    @Autowired
    private ProductRepository productRepository;

@@ -37,9 +46,14 @@ public class JpaMultipleDBIntegrationTest {
        user.setName("John");
        user.setEmail("[email protected]");
        user.setAge(20);
+        Possession p = new Possession("sample");
+        p = possessionRepository.save(p);
+        user.setPossessionList(Arrays.asList(p));
        user = userRepository.save(user);
-
-        assertNotNull(userRepository.findOne(user.getId()));
+        final User result = userRepository.findOne(user.getId());
+        assertNotNull(result);
+        System.out.println(result.getPossessionList());
+        assertTrue(result.getPossessionList().size() == 1);
    }

    @Test
@@ -0,0 +1,13 @@
+*.class
+
+#folders#
+/target
+/neoDb*
+/data
+/src/main/webapp/WEB-INF/classes
+*/META-INF/*
+
+# Packaged files #
+*.jar
+*.war
+*.ear
@@ -0,0 +1,201 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.baeldung</groupId>
+    <artifactId>spring-mvc-web-vs-initializer</artifactId>
+    <version>0.1-SNAPSHOT</version>
+
+    <name>spring-mvc-web-vs-initializer</name>
+    <packaging>war</packaging>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>1.3.6.RELEASE</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
+
+        <!-- Spring -->
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-webmvc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+        </dependency>
+
+        <!-- web -->
+
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>javax.servlet-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>jstl</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+
+        <!-- util -->
+
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>${guava.version}</version>
+        </dependency>
+        
+        <!-- logging -->
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <!-- <scope>runtime</scope> -->
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>jcl-over-slf4j</artifactId>
+            <!-- <scope>runtime</scope> --> <!-- some spring dependencies need to compile against jcl -->
+        </dependency>
+        <dependency> <!-- needed to bridge to slf4j for projects that use the log4j APIs directly -->
+            <groupId>org.slf4j</groupId>
+            <artifactId>log4j-over-slf4j</artifactId>
+        </dependency>
+
+        <!-- test scoped -->
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>3.5.1</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.hamcrest</groupId>
+            <artifactId>hamcrest-core</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.hamcrest</groupId>
+            <artifactId>hamcrest-library</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.easymock</groupId>
+            <artifactId>easymock</artifactId>
+            <version>3.4</version>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+    <dependencyManagement>
+
+        <dependencies>
+
+            <dependency>
+                <groupId>org.springframework</groupId>
+                <artifactId>spring-framework-bom</artifactId>
+                <version>${org.springframework.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>org.springframework</groupId>
+                <artifactId>spring-core</artifactId>
+                <version>${org.springframework.version}</version>
+            </dependency>
+
+        </dependencies>
+
+    </dependencyManagement>
+
+    <build>
+        <finalName>spring-mvc-web-vs-initializer</finalName>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+
+    </build>
+
+    <properties>
+        <!-- Spring -->
+        <org.springframework.version>4.3.1.RELEASE</org.springframework.version>
+        <org.springframework.security.version>4.0.4.RELEASE</org.springframework.security.version>
+        <javassist.version>3.20.0-GA</javassist.version>
+        <jstl.version>1.2</jstl.version>
+
+        <!-- persistence -->
+        <hibernate.version>4.3.11.Final</hibernate.version>
+        <mysql-connector-java.version>5.1.38</mysql-connector-java.version>
+
+        <!-- logging -->
+        <org.slf4j.version>1.7.13</org.slf4j.version>
+        <logback.version>1.1.3</logback.version>
+
+        <!-- various -->
+        <hibernate-validator.version>5.2.2.Final</hibernate-validator.version>
+
+        <!-- util -->
+        <guava.version>19.0</guava.version>
+        <commons-lang3.version>3.4</commons-lang3.version>
+
+        <!-- testing -->
+        <org.hamcrest.version>1.3</org.hamcrest.version>
+        <junit.version>4.12</junit.version>
+        <mockito.version>1.10.19</mockito.version>
+
+        <httpcore.version>4.4.1</httpcore.version>
+        <httpclient.version>4.5</httpclient.version>
+
+        <rest-assured.version>2.9.0</rest-assured.version>
+
+        <!-- maven plugins -->
+        <maven-compiler-plugin.version>3.5.1</maven-compiler-plugin.version>
+        <maven-war-plugin.version>2.6</maven-war-plugin.version>
+        <maven-surefire-plugin.version>2.19.1</maven-surefire-plugin.version>
+        <maven-resources-plugin.version>2.7</maven-resources-plugin.version>
+        <cargo-maven2-plugin.version>1.4.18</cargo-maven2-plugin.version>
+
+    </properties>
+
+</project>
@@ -0,0 +1,26 @@
+package org.baeldung.config;
+
+import org.springframework.web.WebApplicationInitializer;
+import org.springframework.web.context.ContextLoaderListener;
+import org.springframework.web.context.support.AnnotationConfigWebApplicationContext;
+import org.springframework.web.servlet.DispatcherServlet;
+
+import javax.servlet.ServletContext;
+import javax.servlet.ServletException;
+import javax.servlet.ServletRegistration;
+
+public class AppInitializer implements WebApplicationInitializer {
+
+    @Override
+    public void onStartup(ServletContext container) throws ServletException {
+        AnnotationConfigWebApplicationContext context = new AnnotationConfigWebApplicationContext();
+        context.setConfigLocation("org.baeldung.config");
+
+        container.addListener(new ContextLoaderListener(context));
+
+        ServletRegistration.Dynamic dispatcher = container.addServlet("java-servlet", new DispatcherServlet(context));
+        dispatcher.setLoadOnStartup(1);
+        dispatcher.addMapping("/java-servlet/*");
+    }
+
+}
@@ -0,0 +1,25 @@
+package org.baeldung.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.ViewResolver;
+import org.springframework.web.servlet.config.annotation.EnableWebMvc;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
+import org.springframework.web.servlet.view.InternalResourceViewResolver;
+
+@Configuration
+@EnableWebMvc
+@ComponentScan(basePackages = "org.baeldung.controller.java")
+public class MvcConfig extends WebMvcConfigurerAdapter {
+
+    @Bean
+    public ViewResolver viewResolver() {
+        InternalResourceViewResolver viewResolver = new InternalResourceViewResolver();
+        viewResolver.setPrefix("/WEB-INF/view/");
+        viewResolver.setSuffix(".jsp");
+
+        return viewResolver;
+    }
+
+}
@@ -0,0 +1,18 @@
+package org.baeldung.controller.java;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.servlet.ModelAndView;
+
+@Controller
+public class JavaController {
+
+    @RequestMapping(value = "/endpoint")
+    public ModelAndView handleRequestFromJavaConfiguredServlet() {
+        ModelAndView mv = new ModelAndView();
+        mv.setViewName("from-java");
+
+        return mv;
+    }
+
+}
@@ -0,0 +1,18 @@
+package org.baeldung.controller.xml;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.servlet.ModelAndView;
+
+@Controller
+public class XmlController {
+
+    @RequestMapping(value = "/endpoint")
+    public ModelAndView handleRequestFromXmlConfiguredServlet() {
+        ModelAndView mv = new ModelAndView();
+        mv.setViewName("from-xml");
+
+        return mv;
+    }
+
+}
--- a/Show More
+++ b/Show More