小编los*_*jos的帖子

我想尝试使用PostgreSQL与pgadmin进行事务隔离.首先,我在BEGIN中插入了一条新记录但没有COMMIT.

BEGIN;
INSERT INTO my_table(id,value) VALUES (1,'something');

//UNCOMMITTED

然后,我尝试读取未提交的数据

BEGIN TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
SELECT * FROM my_table
COMMIT;

但我找不到新记录.怎么了？

Groovy是非常强大的管理集合.我有一个像这样的列表:

def nameList = ["Jon", "Mike", "Alexia"]

我要做的是迭代10次以从第一个列表中获得具有随机名称的10个人.

10.times{
    Person person = new Person(
    name: nameList.get() //I WANT TO GET A RANDOM NAME FROM THE LIST
    )
}

这不是出于两个显而易见的原因,我没有在我的nameList.get中添加任何索引,而且我没有创建10个不同的Person对象.

1. 如何使用groovy从名单中获取随机元素？
2. 我可以使用groovy的集合属性创建一个包含10个随机名称的人的列表(以简单的方式)吗？

我有一个长时间运行的功能,应插入新行.如何查看此功能的进度？

我认为脏读将起作用所以我阅读http://www.postgresql.org/docs/8.4/interactive/sql-set-transaction.html并提出以下代码并在新会话中运行它:

SET SESSION CHARACTERISTICS AS SERIALIZABLE;

SELECT * FROM MyTable;

Postgres给我一个语法错误.我究竟做错了什么？如果我做对了,那么当长函数仍在运行时,我会看到插入的记录吗？

谢谢

假设我有 Groovy 中的地图列表：

def listOfMaps = [
[k: 1, n: 'Name1', d1: 'a', d2: 'b'],
[k: 2, n: 'Name2', d1: 'c', d2: 'd'],
[k: 1, n: 'Name3', d1: 'e', d2: 'f'],
[k: 4, n: 'Name4', d1: 'g', d2: 'h']]

我需要查找是否存在（或不存在）项目，其中k相等，但n不相等。例如，在本例中，我们有两个地图记录，其中“k”= 1，“n”为“Name1”和“Name3”。我怎样才能找到这样的数据？我想我应该按“k”分组并计算“n”中的不同值，如果“n”中对于某些“k”有超过 1 个唯一值 - 我们找到了这样的数据。我完全陷入困境，所以任何帮助将不胜感激。谢谢

我想在Dataframe(UUID生成器)中添加一个新列.

UUID值看起来像 21534cf7-cff9-482a-a3a8-9e7244240da7

我的研究:

我试过withColumn火花的方法.

val DF2 = DF1.withColumn("newcolname", DF1("existingcolname" + 1)

因此DF2将newcolname在所有行中添加一个额外的列,并添加1.

根据我的要求,我想要一个可以生成UUID的新列.

我正在学习 PostgreSQL，我遇到了一个小问题。

我有这样的文字：

'{1,1}'

并想创建一个包含我的两个值的数组，以便我可以访问它们。我怎么做 ？我试过

SELECT string_to_array('{1,1}', '{', '}', ',');

但这似乎不起作用。

试图测试Spark Structured Streams ......并且失败......我该如何正确测试它们？

我从这里跟踪了一般的Spark测试问题,我最接近的尝试是[ 1 ]看起来像:

import simpleSparkTest.SparkSessionTestWrapper
import org.scalatest.FunSpec  
import org.apache.spark.sql.types.{StringType, IntegerType, DoubleType, StructType, DateType}
import org.apache.spark.sql.streaming.OutputMode

class StructuredStreamingSpec extends FunSpec with SparkSessionTestWrapper {

  describe("Structured Streaming") {

    it("Read file from system") {

      val schema = new StructType()
        .add("station_id", IntegerType)
        .add("name", StringType)
        .add("lat", DoubleType)
        .add("long", DoubleType)
        .add("dockcount", IntegerType)
        .add("landmark", StringType)
        .add("installation", DateType)

      val sourceDF = spark.readStream
        .option("header", "true")
        .schema(schema)
        .csv("/Spark-The-Definitive-Guide/data/bike-data/201508_station_data.csv")
        .coalesce(1)

      val countSource = sourceDF.count()

      val query = sourceDF.writeStream
        .format("memory")
        .queryName("Output")
        .outputMode(OutputMode.Append())
        .start()
        .processAllAvailable()

      assert(countSource === 70) …

ORM 的基础是与对象的映射。但是，出于某种原因，我不想创建用于运行查询的对象。

有什么方法可以在不创建实体（托管类）的情况下运行本机 SQL 查询？

如何有效地附加到大文件.我有一个必须不断附加到文件的进程,随着文件大小的增加,性能似乎也会减慢.无论如何都要指定一个大的缓冲区大小append

我正在创建一个管理页面,其中包含一些我想要动态设置的logback属性,其中一个是我发送系统警报的管理员电子邮件.api for the SMTPAppender有添加到"to"地址列表的方法,或者将它们作为列表获取,但我没有找到任何要清除的内容,删除任何内容或更新它们.我该怎么做？

我目前看到两种选择:

1. 一种选择是删除appender并使用新属性创建一个新的(yuck).
2. 弄清楚如何通过Joran直接配置它(也许你好吗？).

我正在向前推进(2),但如果有更好的方法请发帖.