要先在MySQL中按特定字段值排序，请使用ORDER BY FIELD()。让我们首先创建一个表-mysql> create table DemoTable849(Color varchar(100));
使用插入命令在表中插入一些记录-mysql> insert into DemoTable849 values('RED');
mysql> insert into DemoTable849 values('ORANGE');
mysql> insert into DemoTable849 values('BLUE');
mysql> insert into DemoTable849 values('GREEN');
使用select语句显示表中的所有记录-mysql> select *from DemoTable849;
这将产生以下输出-+--------+
| Color  |
+--------+
| RED    |
| ORANGE |
| BLUE   |
| GREEN  |
+--------+
4 rows in set (0.00 sec)
以下是先按特定值排序的查询-mysql> select *from DemoTable849 order by field(Color,'RED','GREEN','BLUE','ORANGE');
这将产生以下输出-+--------+
| Color  |
+--------+
| RED    |
| GREEN  |
| BLUE   |
| ORANGE |
+--------+
4 rows in set (0.00 sec)

1.写一个创建mysql表的工具类Utility.scala

/**
    * 创建mysql的表
    *
    * @param url      msyql的url
    * @param userName mysql用户名
    * @param password mysql密码
    * @param tables   注册的表名集合
    * @param spark    SparkSession
    */
def createMysqlTempView(url: String, userName: String, password: String, tables: List[String], spark: SparkSession): Unit = {
  val proBasicData = new Properties()
  proBasicData.put("user", userName)
  proBasicData.put("password", password)

  val dfs = for {
    table <- tables
  } yield (table, spark.read.jdbc(url, table, proBasicData))

  for {
    (name, df) <- dfs
  } df.createOrReplaceTempView(name)
}

2.main.scala中调用

    Utility.createMysqlTempView(MySQLConnetionUtility.MOVIEBASIC_URL, MySQLConnetionUtility.MOVIEBASIC_USERNAME, MySQLConnetionUtility.MOVIEBASIC_PASSWORD,
      List("表名"), spark)

 

您当然可以在两个应用程序之间共享一个数据库。
为了在应用程序之间共享数据(只要它们是由同一个发行者发布的)，您需要在这两个应用程序的AndroidManifest.xml中指定一个共享的用户id。
(这是没有文档的，但是共享的用户id需要是至少一个点分隔符的字符串)
其余的操作都很简单，您不需要在数据库路径上乱搞。只需在两个应用程序中使用相同的DBAdapter即可。在承载数据库的应用程序中，使用本机上下文调用DBAdapter。DBadapter hostDBAdapter = new DbAdapter(getApplicationContext());performerDBadapter.open();
在第二个应用程序中，使用数据库托管应用程序的上下文访问数据库。
首先，定义共享上下文：Context sharedContext = null;
try {
sharedContext = this.createPackageContext("replace.with.host.package.name", Context.CONTEXT_INCLUDE_CODE);
if (sharedContext == null) {
return;
}
} catch (Exception e) {
String error = e.getMessage();
return;
}
然后使用共享上下文打开DBAdapter：DbAdapter sharedDBadapter = new PerformerDbAdapter(sharedContext);sharedDBadapter.open();
最后，如果在清单中设置共享用户id之前就存在数据库，则需要卸载/重新安装物理设备上的应用程序，以免将自己锁在数据库之外(Sqliterror 14)。另一方面，仿真器可能会被证明更宽容。总之，如果你的应用程序是在Android市场上发布的，那么在事后设置一个共享的用户ID是行不通的。
希望这能帮上忙。

小编典典
通常，您在连接时会在DSN中指定数据库。但是，如果您要创建一个新数据库，则显然您不能在创建该数据库之前将其指定为DSN。
您可以使用以下USE语句更改默认数据库：
$dbh = new PDO("mysql:host=...;dbname=mysql", ...);
$dbh->query("create database newdatabase");
$dbh->query("use newdatabase");
随后的CREATE TABLE语句将在您的新数据库中创建。
来自@Mike的评论：
当您像这样切换数据库时，似乎会强制PDO模拟准备好的语句。将PDO ::
ATTR_EMULATE_PREPARES设置为false，然后尝试使用另一个数据库将失败。
我只是做了一些测试，但我看不到这种情况。更改数据库仅在服务器上进行，并且不会更改客户端中PDO的配置。这是一个例子：
// connect to database
try {
$pdo = new PDO('mysql:host=huey;dbname=test', 'root', 'root');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, false);
} catch(PDOException $err) {
die($err->getMessage());
}
$stmt = $pdo->prepare("select * from foo WHERE i = :i");
$result = $stmt->execute(array("i"=>123));
print_r($stmt->fetchAll(PDO::FETCH_ASSOC));
$pdo->exec("use test2");
$stmt = $pdo->prepare("select * from foo2 WHERE i = :i AND i = :i");
$result = $stmt->execute(array("i"=>456));
print_r($stmt->fetchAll(PDO::FETCH_ASSOC));
如果您说的是真的，那么这应该可以正常工作。仅当PDO ::
ATTR_EMULATE_PREPARES为true时，PDO才能多次使用给定的命名参数。因此，如果您说将此属性设置为true作为更改数据库的副作用，那么它应该可以工作。
但这不起作用-会收到错误消息“无效的参数号”，该错误指示未模拟的准备好的语句仍然有效。
2020-05-17