将系统日期传递给 Sqoop
Passing System date to Sqoop
我有一个配置单元 table 假设 student( id, name , date) 并且在 mysql 我有一个 table 命名为 student(id, name) ，使用 sqoop 我'我正在逐步导入数据，我希望在导入时添加系统日期，我该如何实现？
Sqoop 查询：
sqoop import --connect jdbc:mysql:dbName --username userName --password pass --m mapperNo --query 'select id, name from syudent WHERE $CONDITIONS' --target-dir outputPath --append --check-column id --incremental append --last-value last_Value
我正在 shell 脚本中编写整个脚本，并使用 shell 命令获取当前日期，并希望将其传递到 sqoop 查询中，以便在导入时添加当前日期日期 .
你可以通过变量，
例如：
cur_date=$(date +%d/%m/%y)
sqoop import --connect jdbc:mysql:dbName --username userName --password pass --m mapperNo --query "select id, name, '$cur_date' from syudent WHERE $CONDITIONS" --target-dir outputPath --append --check-column id --incremental append --last-value last_Value
让我知道这是否有效。
我有一个配置单元 table 假设 student( id, name , date) 并且在 mysql 我有一个 table 命名为 student(id, name) ，使用 sqoop 我'我正在逐步导入数据，我希望在导入时添加系统日期，我该如何实现？
Sqoop 查询：
sqoop import --connect jdbc:mysql:dbName --username userName --password pass --m mapperNo --query 'select id, name from syudent WHERE $CONDITIONS' --target-dir outputPath --append --check-column id --incremental append --last-value last_Value
我正在 shell 脚本中编写整个脚本，并使用 shell 命令获取当前日期，并希望将其传递到 sqoop 查询中，以便在导入时添加当前日期日期 .
你可以通过变量，
例如：
cur_date=$(date +%d/%m/%y)
sqoop import --connect jdbc:mysql:dbName --username userName --password pass --m mapperNo --query "select id, name, '$cur_date' from syudent WHERE $CONDITIONS" --target-dir outputPath --append --check-column id --incremental append --last-value last_Value
让我知道这是否有效。