com.facebook.presto.execution.QueryStateMachine.getQueryInfoWithoutDetails()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(13.0k)|赞(0)|评价(0)|浏览(76)

本文整理了Java中com.facebook.presto.execution.QueryStateMachine.getQueryInfoWithoutDetails方法的一些代码示例，展示了QueryStateMachine.getQueryInfoWithoutDetails的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryStateMachine.getQueryInfoWithoutDetails方法的具体详情如下：
包路径：com.facebook.presto.execution.QueryStateMachine
类名称：QueryStateMachine
方法名：getQueryInfoWithoutDetails

QueryStateMachine.getQueryInfoWithoutDetails介绍

暂无

代码示例

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Override
public QueryInfo getQueryInfo()
{
  return stateMachine.getQueryInfoWithoutDetails();
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testCommit()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .setTransactionId(transactionManager.beginTransaction(false))
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "COMMIT", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertTrue(stateMachine.getSession().getTransactionId().isPresent());
  assertEquals(transactionManager.getAllTransactionInfos().size(), 1);
  new CommitTask().execute(new Commit(), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
  assertTrue(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testUnknownTransactionRollback()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .setTransactionId(TransactionId.create()) // Use a random transaction ID that is unknown to the system
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "ROLLBACK", session, URI.create("fake://uri"), true, transactionManager, executor);
  new RollbackTask().execute(new Rollback(), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
  assertTrue(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId()); // Still issue clear signal
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testStartTransaction()
    throws Exception
{
  Session session = sessionBuilder()
      .setClientTransactionSupport()
      .build();
  TransactionManager transactionManager = createTestTransactionManager();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "START TRANSACTION", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertFalse(stateMachine.getSession().getTransactionId().isPresent());
  new StartTransactionTask().execute(new StartTransaction(ImmutableList.of()), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertTrue(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertEquals(transactionManager.getAllTransactionInfos().size(), 1);
  TransactionInfo transactionInfo = transactionManager.getTransactionInfo(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().get());
  assertFalse(transactionInfo.isAutoCommitContext());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testRollback()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .setTransactionId(transactionManager.beginTransaction(false))
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "ROLLBACK", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertTrue(stateMachine.getSession().getTransactionId().isPresent());
  assertEquals(transactionManager.getAllTransactionInfos().size(), 1);
  new RollbackTask().execute(new Rollback(), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
  assertTrue(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testNoTransactionRollback()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "ROLLBACK", session, URI.create("fake://uri"), true, transactionManager, executor);
  try {
    try {
      new RollbackTask().execute(new Rollback(), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (PrestoException e) {
    assertEquals(e.getErrorCode(), NOT_IN_TRANSACTION.toErrorCode());
  }
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testStartTransactionExplicitModes()
    throws Exception
{
  Session session = sessionBuilder()
      .setClientTransactionSupport()
      .build();
  TransactionManager transactionManager = createTestTransactionManager();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "START TRANSACTION", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertFalse(stateMachine.getSession().getTransactionId().isPresent());
  new StartTransactionTask().execute(new StartTransaction(ImmutableList.of(new Isolation(Isolation.Level.SERIALIZABLE), new TransactionAccessMode(true))), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertTrue(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertEquals(transactionManager.getAllTransactionInfos().size(), 1);
  TransactionInfo transactionInfo = transactionManager.getTransactionInfo(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().get());
  assertEquals(transactionInfo.getIsolationLevel(), IsolationLevel.SERIALIZABLE);
  assertTrue(transactionInfo.isReadOnly());
  assertFalse(transactionInfo.isAutoCommitContext());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testNonTransactionalClient()
    throws Exception
{
  Session session = sessionBuilder().build();
  TransactionManager transactionManager = createTestTransactionManager();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "START TRANSACTION", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertFalse(stateMachine.getSession().getTransactionId().isPresent());
  try {
    try {
      new StartTransactionTask().execute(new StartTransaction(ImmutableList.of()), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (PrestoException e) {
    assertEquals(e.getErrorCode(), INCOMPATIBLE_CLIENT.toErrorCode());
  }
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testNoTransactionCommit()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "COMMIT", session, URI.create("fake://uri"), true, transactionManager, executor);
  try {
    try {
      new CommitTask().execute(new Commit(), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (PrestoException e) {
    assertEquals(e.getErrorCode(), NOT_IN_TRANSACTION.toErrorCode());
  }
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testStartTransactionTooManyAccessModes()
    throws Exception
{
  Session session = sessionBuilder()
      .setClientTransactionSupport()
      .build();
  TransactionManager transactionManager = createTestTransactionManager();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "START TRANSACTION", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertFalse(stateMachine.getSession().getTransactionId().isPresent());
  try {
    try {
      new StartTransactionTask().execute(new StartTransaction(ImmutableList.of(new TransactionAccessMode(true), new TransactionAccessMode(true))), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (SemanticException e) {
    assertEquals(e.getCode(), INVALID_TRANSACTION_MODE);
  }
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testNestedTransaction()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .setTransactionId(TransactionId.create())
      .setClientTransactionSupport()
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "START TRANSACTION", session, URI.create("fake://uri"), true, transactionManager, executor);
  try {
    try {
      new StartTransactionTask().execute(new StartTransaction(ImmutableList.of()), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (PrestoException e) {
    assertEquals(e.getErrorCode(), NOT_SUPPORTED.toErrorCode());
  }
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testUnknownTransactionCommit()
    throws Exception
{
  TransactionManager transactionManager = createTestTransactionManager();
  Session session = sessionBuilder()
      .setTransactionId(TransactionId.create()) // Use a random transaction ID that is unknown to the system
      .build();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "COMMIT", session, URI.create("fake://uri"), true, transactionManager, executor);
  try {
    try {
      new CommitTask().execute(new Commit(), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (PrestoException e) {
    assertEquals(e.getErrorCode(), UNKNOWN_TRANSACTION.toErrorCode());
  }
  assertTrue(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId()); // Still issue clear signal
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Test
public void testStartTransactionTooManyIsolationLevels()
    throws Exception
{
  Session session = sessionBuilder()
      .setClientTransactionSupport()
      .build();
  TransactionManager transactionManager = createTestTransactionManager();
  QueryStateMachine stateMachine = QueryStateMachine.begin(new QueryId("query"), "START TRANSACTION", session, URI.create("fake://uri"), true, transactionManager, executor);
  assertFalse(stateMachine.getSession().getTransactionId().isPresent());
  try {
    try {
      new StartTransactionTask().execute(new StartTransaction(ImmutableList.of(new Isolation(Isolation.Level.READ_COMMITTED), new Isolation(Isolation.Level.READ_COMMITTED))), transactionManager, metadata, new AllowAllAccessControl(), stateMachine).join();
      fail();
    }
    catch (CompletionException e) {
      throw Throwables.propagate(e.getCause());
    }
  }
  catch (SemanticException e) {
    assertEquals(e.getCode(), INVALID_TRANSACTION_MODE);
  }
  assertTrue(transactionManager.getAllTransactionInfos().isEmpty());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().isClearTransactionId());
  assertFalse(stateMachine.getQueryInfoWithoutDetails().getStartedTransactionId().isPresent());
}

内容来源于网络，如有侵权，请联系作者删除！

QueryStateMachine

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    QueryStateMachine类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com