compsci-industry
/
TechEmpower.FrameworkBenchmarks
tükrözi: https://github.com/TechEmpower/FrameworkBenchmarks.git


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
							require "kemal"
require "pg"
require "pool/connection"
require "html_builder"

# Compose Objects (like Hash) to have a to_json method
require "json/to_json"

DB = ConnectionPool.new(capacity: 25, timeout: 0.01) do
  PG.connect("postgres://benchmarkdbuser:benchmarkdbpass@#{ENV["DBHOST"]? || "127.0.0.1"}/hello_world")
end

class CONTENT
  UTF8 = "; charset=UTF-8"
  JSON = "application/json"
  PLAIN = "text/plain"
  HTML = "text/html" + UTF8
end

ID_MAXIMUM = 10_000

private def randomWorld
  id = rand(1..ID_MAXIMUM)
  conn = DB.checkout
  result = conn.exec({Int32, Int32}, "SELECT id, randomNumber FROM world WHERE id = $1", [id]).rows.first
  DB.checkin(conn)
  {:id => result[0], :randomNumber => result[1]}
end

private def setWorld(world)
  conn = DB.checkout
  result = conn.exec("UPDATE world set randomNumber = $1 where id = $2", [world[:randomNumber], world[:id]])
  DB.checkin(conn)
  world
end

private def fortunes
  data = [] of  Hash(Symbol, (String | Int32))

  DB.connection.exec({Int32, String}, "select id, message from Fortune").rows.each do |row|
    data.push({:id => row[0], :message => row[1]})
  end
  data
end

private def sanitizedQueryCount(request)
  queries = request.params["queries"] as String
  return 1 if queries.empty? || queries.to_i?.nil?
  if queries.to_i > 500
    queries = 500
  elsif queries.to_i < 1
    queries = 1
  end
  queries.to_i
end

before_all do |env|
  env.response.headers["Server"] = "Kemal"
  env.response.headers["Date"] = Time.now.to_s
end

#
# Basic Tests
#

# Test 1: JSON Serialization
get "/json", do |env|
  env.response.content_type = CONTENT::JSON
  { :message => "Hello, World!" }.to_json
end

# Test 6: Plaintext
get "/plaintext", do |env|
  env.response.content_type = CONTENT::PLAIN
  "Hello, World!"
end

#
# Postgres DatabaseTests
#

# Postgres Test 2: Single database query
get "/db", do |env|
  env.response.content_type = CONTENT::JSON
  randomWorld.to_json
end

# Postgres Test 3: Multiple database query
get "/queries", do |env|
  results = (1..sanitizedQueryCount(env)).map do
    randomWorld
  end

  env.response.content_type = CONTENT::JSON
  results.to_json
end

# Postgres Test 4: Fortunes
get "/fortunes", do |env|
  data = fortunes

  additional_fortune = {
    :id => 0,
    :message => "Additional fortune added at request time."
  }
  data.push(additional_fortune)

  data.sort! do |a, b|
    a[:message].to_s <=> b[:message].to_s
  end

  # New builder for each request!
  html = HTML::Builder.new.build do
    html {
      head {
        title { text "Fortunes" }
      }
      body {
        table {
          tr {
            thead { text "id" }
            thead { text "message" }
          }
          data.each { |e|
            tr {
              td { text e[:id].to_s }
              td { text e[:message].to_s }
            }
          }
        }
      }
    }
  end

  # Doctype not available in builder
  # builder only supports `thead`, tests need to see `th`
  env.response.content_type = CONTENT::HTML
  "<!doctype html>" + html.gsub("thead", "th")
end

# Postgres Test 5: Database Updates
get "/updates", do |env|
  updated = (1..sanitizedQueryCount(env)).map do
    world = randomWorld
    world[:randomNumber] = rand(1..ID_MAXIMUM)
    setWorld(world)
  end

  env.response.content_type = CONTENT::JSON
  updated.to_json
end