peschkaj

 SELECT QueryPlanHash,
        CASE WHEN QueryType LIKE '%Stored Procedure%' THEN 
             QueryPlan.value('declare namespace p="http://schemas.microsoft.com/sqlserver/2004/07/showplan";
                              sum(//p:StmtSimple/@StatementSubTreeCost)', 'float')
             ELSE  
            QueryPlan.value('declare namespace p="http://schemas.microsoft.com/sqlserver/2004/07/showplan";
                             sum(//p:StmtSimple[xs:hexBinary(substring(@QueryPlanHash, 3)) = xs:hexBinary(sql:column("QueryPlanHash"))]/@StatementSubTreeCost)', 'float') 
             END AS cost, *
  FROM #procs

peschkaj

SELECT * FROM Sales.SalesOrderHeader AS soh



CREATE INDEX jp_filters_not_offline 
    ON Sales.SalesOrderHeader (OrderDate) 
        INCLUDE (SalesOrderID)
        WHERE OnlineOrderFlag <> 0
GO

peschkaj

generated.cs is produced by Protobuf-net - you'll notice line 5's hilarious half-complete enumeration. This happens because CLR enums are value types and can't technically be null.

Corrected.cs contains my corrections on line 5. I think that this should let us get around these problems - it's good to know, though, because these do occur in a few other places in the protocol buffers interface.

peschkaj

# -*- shell-script -*-

function riak_dev_cleanup_stage() {
  for d in ~/Projects/riak/dev/dev{2,3,4,5}; do
    $d/bin/riak-admin cluster leave;
  done

  ~/Projects/riak/dev/dev1/bin/riak-admin cluster plan
}

peschkaj

using System;
using CorrugatedIron;
using CorrugatedIron.Models;
using CorrugatedIron.Util;
using ProtoBuf;

namespace TestAllowMult
{
    public class MainClass
    {

peschkaj

function riak_dev_cleanup_stage() {
  for d in ~/Projects/riak/dev/dev{2,3,4,5}; do
    $d/bin/riak-admin cluster leave;
  done

  ~/Projects/riak/dev/dev1/bin/riak-admin cluster plan
}

function riak_dev_cleanup_commit() {
  ~/Projects/riak/dev/dev1/bin/riak-admin cluster commit

peschkaj

function riak_dev_cleanup_stage() {
  for d in ~/Projects/riak/dev/dev{2,3,4,5}; do
    $d/bin/riak-admin cluster leave;
  done

  ~/Projects/riak/dev/dev1/bin/riak-admin cluster plan
}

function riak_dev_cleanup_commit() {
  ~/Projects/riak/dev/dev1/bin/riak-admin cluster commit

peschkaj

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Cassandra;
using Cassandra.Data;
using Cassandra.Data.Linq;
using metrics.Core;
using metrics.Reporting;
using System.Diagnostics;

peschkaj

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Cassandra;
using Cassandra.Data;
using Cassandra.Data.Linq;
using metrics.Core;
using metrics.Reporting;
using System.Diagnostics;

peschkaj

        public RiakResult<IEnumerable<string>> StreamListBuckets()
        {
            var lbReq = new RpbListBucketsReq { stream = true };
            var result = UseDelayedConnection((conn, onFinish) =>
                                              conn.PbcWriteStreamRead<RpbListBucketsReq, RpbListBucketsResp>(lbReq, lbr => lbr.IsSuccess && !lbr.Value.done, onFinish));

            if(result.IsSuccess)
            {
                var buckets = result.Value.Where(r => r.IsSuccess).SelectMany(r => r.Value.buckets).Select(k => k.FromRiakString());
                return RiakResult<IEnumerable<string>>.Success(buckets);