Merge Java 8 samples into basic one.

cassandra/example/src/main/java/example/springdata/cassandra/streamoptional/CassandraConfiguration.java

@@ -0,0 +1,25 @@
+/*
+ * Copyright 2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.cassandra.streamoptional;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author Mark Paluch
+ */
+@SpringBootApplication
+class CassandraConfiguration {
+}

cassandra/example/src/main/java/example/springdata/cassandra/streamoptional/Order.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright 2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.cassandra.streamoptional;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+import java.time.ZoneId;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.cassandra.core.mapping.Table;
+
+/**
+ * @author Mark Paluch
+ */
+@Table("pizza_orders")
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Order {
+
+	@Id String id;
+	LocalDate orderDate;
+	ZoneId zoneId;
+}

cassandra/example/src/main/java/example/springdata/cassandra/streamoptional/OrderRepository.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright 2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.cassandra.streamoptional;
+
+import java.time.LocalDate;
+import java.time.ZoneId;
+
+import org.springframework.data.cassandra.repository.Query;
+import org.springframework.data.repository.Repository;
+
+/**
+ * Repository to manage {@link Order} instances.
+ *
+ * @author Mark Paluch
+ */
+public interface OrderRepository extends Repository<Order, String> {
+
+	/**
+	 * Method parameters are converted according the registered Converters into Cassandra types.
+	 */
+	@Query("SELECT * from pizza_orders WHERE orderdate = ?0 and zoneid = ?1 ALLOW FILTERING")
+	Order findOrderByOrderDateAndZoneId(LocalDate orderDate, ZoneId zoneId);
+
+	void deleteAll();
+
+	Order save(Order order);
+}

cassandra/example/src/main/java/example/springdata/cassandra/streamoptional/Person.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright 2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package example.springdata.cassandra.streamoptional;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.cassandra.core.mapping.Table;
+
+/**
+ * @author Mark Paluch
+ */
+@Table
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Person {
+
+	@Id String id;
+	String firstname, lastname;
+}

cassandra/example/src/main/java/example/springdata/cassandra/streamoptional/PersonRepository.java

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.cassandra.streamoptional;
+
+import java.util.Optional;
+import java.util.stream.Stream;
+
+import org.springframework.data.cassandra.repository.Query;
+import org.springframework.data.repository.Repository;
+
+/**
+ * Repository to manage {@link Person} instances.
+ *
+ * @author Mark Paluch
+ */
+public interface PersonRepository extends Repository<Person, String> {
+
+	Optional<Person> findById(String id);
+
+	Stream<Person> findAll();
+
+	/**
+	 * Sample method to derive a query from using JDK 8's {@link Optional} as return type.
+	 *
+	 * @param id
+	 * @return
+	 */
+	@Query("select * from person where id = ?0")
+	Optional<Person> findPersonById(String id);
+
+	/**
+	 * Sample default method to show JDK 8 feature support.
+	 *
+	 * @param person
+	 * @return
+	 */
+	default Optional<Person> findByPerson(Person person) {
+		return findPersonById(person == null ? null : person.id);
+	}
+
+	void deleteAll();
+
+	Person save(Person person);
+}

cassandra/example/src/main/java/example/springdata/cassandra/streamoptional/package-info.java

@@ -0,0 +1,20 @@
+/*
+ * Copyright 2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Package showing Java 8 features.
+ */
+package example.springdata.cassandra.streamoptional;