2

我想从数据库中提取一个文本字段并将其插入到其他数据库中。因此，在提取时，我在选择测试时使用了 REPLACE(message_text,'\'', '"')。我给了我一个错误。我从我的 select 语句中更改了它，并在启动全局变量时这样做了。etl.globals [ 'message_text'] = message_text;

我仍然在插入语句中遇到错误

insert into lcs_al_user_likes(user_id,liked_user_id,post_content,loop_id) values('${etl.globals['posted_by']}','${etl.globals['liked_user_id']}','${etl.gl‌​obals['message_text']}',?batchLoopCounter);

说

*您的 SQL 语法有错误检查与您的 MySQL 服务器版本相对应的手册，以便在第 1 行的 'message_text']}')' 附近使用正确的语法*

我认为它没有得到全局变量。我这么说是因为当我使用 log 打印它的值时，它只是给了我

${etl.globals['message_text']}

作为输出。所以请在这里帮助我。

<query connection-id="lcsDBConnection"> 
     SELECT forum_topic_post_id AS forum_topic_post_id, posted_by AS posted_by,message_text as message_text FROM lcs_tbl_forum_topic_post WHERE like_count>0 LIMIT ?batchSize OFFSET ?queryCounter ; 
     <script connection-id="jexl"> 
         etl.globals['forum_topic_post_id'] = forum_topic_post_id; 
         etl.globals['posted_by'] = posted_by; 
         etl.globals['message_text'] = message_text.replace('\'', '"'); 
     </script>
4

1 回答 1

0

看起来问题出在 INSERT 语句中，您应该使用准备好的语句参数转义：

INSERT INTO lcs_al_user_likes(user_id,liked_user_id,post_content,loop_id) values(?{etl.globals['posted_by']},?{etl.globals['liked_user_id']},?{etl.gl‌​obals['message_text']},?batchLoopCounter);

顺便说一句，据我了解，您最初的问题是引号破坏了插入语句，因此在这种情况下使用 ?{parameter} 语法，您根本不需要使用 replace(...) 函数。

于 2012-11-12T16:08:21.983 回答