Skip to content

Instantly share code, notes, and snippets.

View olim7t's full-sized avatar

Olivier Michallat olim7t

  • DataStax
  • San Jose, CA
View GitHub Profile
@olim7t
olim7t / DriverDemo.java
Created November 13, 2015 11:45
Standalone program that can be used as a template to reproduce Java driver issues
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
import com.datastax.driver.mapping.Mapper;
import com.datastax.driver.mapping.MappingManager;
import com.datastax.driver.mapping.annotations.Frozen;
import com.datastax.driver.mapping.annotations.PartitionKey;
import com.datastax.driver.mapping.annotations.Table;
import com.datastax.driver.mapping.annotations.UDT;
public class DriverDemo {
@olim7t
olim7t / GatherAllListenAddresses.java
Created January 7, 2016 09:43
Use custom LBP to query system.local on each host
import com.datastax.driver.core.*;
import com.datastax.driver.core.policies.Policies;
import java.net.InetAddress;
public class GatherAllListenAddresses {
public static void main(String[] args) {
Cluster cluster = null;
try {
cluster = Cluster.builder()
@olim7t
olim7t / IntToDateDemo.java
Last active January 21, 2016 16:04
Custom codec to handle CQL `date` columns as Java ints
import com.datastax.driver.core.*;
import com.datastax.driver.core.exceptions.InvalidTypeException;
import java.nio.ByteBuffer;
public class LongToDateDemo {
public static class LongToDateCodec extends TypeCodec<Integer> {
// Piggyback on the default codecs' implementation
@olim7t
olim7t / Read2MbBlobs.java
Last active April 5, 2016 09:08
Test program to debug blob reading issue
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.PreparedStatement;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import java.nio.ByteBuffer;
import java.util.concurrent.TimeUnit;
public class Read2MbBlobs {
public static void main(String[] args) {
package com.datastax.oss.driver.mapper;
import static com.datastax.oss.driver.api.querybuilder.QueryBuilder.bindMarker;
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.cql.BatchStatement;
import com.datastax.oss.driver.api.core.cql.BatchStatementBuilder;
import com.datastax.oss.driver.api.core.cql.BoundStatementBuilder;
import com.datastax.oss.driver.api.core.cql.DefaultBatchType;
import com.datastax.oss.driver.api.core.cql.PreparedStatement;
@olim7t
olim7t / Hello.scala
Created July 26, 2019 18:47
Test project to reproduce JAVA-1252, and check if JAVA-2365 will cause the same issue
// (in src/main/scala/example/)
package example
import com.datastax.oss.driver.api.core.cql.BatchType
import com.datastax.driver.dse.DseCluster
object Hello extends App {
// Test if JAVA-2365 creates a problem:
println(BatchType.LOGGED)
@olim7t
olim7t / AliasExample.java
Last active January 29, 2021 22:14
Multiple selections of the same field with different arguments, under different aliases
import graphql.GraphQL;
import graphql.Scalars;
import graphql.schema.DataFetcher;
import graphql.schema.DataFetchingEnvironment;
import graphql.schema.GraphQLSchema;
import static graphql.schema.FieldCoordinates.coordinates;
import static graphql.schema.GraphQLArgument.newArgument;
import static graphql.schema.GraphQLCodeRegistry.newCodeRegistry;
import static graphql.schema.GraphQLFieldDefinition.newFieldDefinition;