Java Database类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.github.davidmoten.rx.jdbc.Database类的典型用法代码示例。如果您正苦于以下问题：Java Database类的具体用法？Java Database怎么用？Java Database使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Database类属于com.github.davidmoten.rx.jdbc包，在下文中一共展示了Database类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

    //After running this code you have no guarantee that the update person set score=1 ran before the update person set score=2.
    Database adb = db.asynchronous();
    Observable
            .just(1, 2, 3)
            .lift(adb.update("update person set score = ?")
                    .parameterOperator());

    // To run those queries synchronously either use a transaction:
    Observable
            .just(1, 2, 3)
            .lift(adb.update("update person set score = ?")
                    .dependsOn(db.beginTransaction())
                    .parameterOperator())
            .lift(adb.commitOnCompleteOperator());
}

开发者ID:edgar615，项目名称:javase-study，代码行数:19，代码来源:AsynchronousExample.java

示例2: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(1);
        Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");
        db.select("select alarm_user_id, alarm_user_name from alarm_user where alarm_user_id = ?")
                .parameter("001205151325580000420758933716")
                .get(rs -> {
                    System.out.println(Thread.currentThread().getId());
                    return rs.getString(1) + "-" + rs.getString(2);
                })
                .singleOrDefault("no record")
                .subscribe(rs -> {
                    latch.countDown();
                    System.out.println(Thread.currentThread().getId());
                    System.out.println("subscribe");
                    System.out.println(rs);
                });
//        .get(rs -> rs.getString(1) + "-" + rs.getString(2))

        latch.await();

    }

开发者ID:edgar615，项目名称:javase-study，代码行数:22，代码来源:GetNoRecordExample.java

示例3: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
        Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");
        List<String> names = db.select("select alarm_user_name from alarm_user where  alarm_user_id = :alarmUserId")
                .parameter("alarmUserId", "001205151324410000020758933716").getAs(String.class).toList().toBlocking().single();
        System.out.println(names);

        Map<String, String> map = new HashMap<String, String>();
        map.put("alarmUserId", "001205151324410000020758933716");
        names = db.select("select alarm_user_name from alarm_user where  alarm_user_id = :alarmUserId")
                .parameters(map).getAs(String.class).toList().toBlocking().single();
        System.out.println(names);

//        Observable<String> names = db
//                .select("select name from person where score >= :min and score <=:max")
//                .parameters(Observable.just(map1, map2))
//                .getAs(String.class);
    }

开发者ID:edgar615，项目名称:javase-study，代码行数:18，代码来源:NamedParameterExample.java

示例4: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
        Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

        // use composition to find the first person alphabetically with
// a score less than the person with the last name alphabetically
// whose name is not XAVIER. Two threads and connections will be used.
        Observable<String> ids = db.select("select alarm_user_id from alarm_user  order by alarm_user_id limit ?")
                .parameter(1).getAs(String.class).last();
        String names = db.select("select alarm_user_name from alarm_user where alarm_user_id = ?")
                .parameters(ids).getAs(String.class).first().toBlocking().single();
        System.out.println(names);

        // alternatively using the Observable.lift() method to chain everything in one command:
        names = db.select("select alarm_user_id from alarm_user  order by alarm_user_id limit ?")
                .parameter(1).getAs(String.class).last().lift(db.select("select alarm_user_name from alarm_user where alarm_user_id = ?")
                .parameterOperator().getAs(String.class)).first().toBlocking().single();
        System.out.println(names);
    }

开发者ID:edgar615，项目名称:javase-study，代码行数:19，代码来源:ComposeExample.java

示例5: ExtractorClient

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public ExtractorClient(Config config) {
    this.dataSource = DatasourceBuilder.from(config.getConfig("db"));
    this.databaseName = new DatabaseName(config.getString("database.name"));
    ParseTableConfig parseTableConfig = new ParseTableConfig(dataSource);
    this.sqlFlavour = detectSqlFlavour(config.getConfig("db"));
    this.tableConfigs = parseTableConfig.parse(config);
    this.callbackName = optionalString(config, "strategy.callbackName");
    this.redisson = createRedisso(config);
    this.timeZone = TimeZoneConfig.timeZone(config);
    this.database = new Database(new DataSourceConnectionProvider(dataSource), () -> Schedulers.io());
}

开发者ID:jamescross91，项目名称:shyft-extractor，代码行数:12，代码来源:ExtractorClient.java

示例6: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
/**
 * create table person(
 id bigint auto_increment primary key,
 score int
 )
 * @param args
 */
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

    List<Integer> mins = Observable
            // do 3 times
            .just(11, 12, 13)
                    // begin transaction for each item
            .lift(db.beginTransactionOnNextOperator())
                    // update all scores to the item
            .lift(db.update("update person set score=?").parameterOperator())
                    // to empty parameter list
            .map(toEmpty())
                    // increase score
            .lift(db.update("update person set score=score + 5").parameterListOperator())
                    //only expect one result so can flatten
            .lift(RxUtil.<Integer>flatten())
                    // commit transaction
            .lift(db.commitOnNextOperator())
                    // to empty lists
            .map(toEmpty())
                    // return count
            .lift(db.select("select min(score) from person").parameterListOperator()
                    .getAs(Integer.class))
                    // list the results
            .toList()
                    // block and get
            .toBlocking().single();

    System.out.println(mins);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:38，代码来源:OnNextTransactionEaxmple.java

示例7: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

    long count = db
            .select("select count(*) from note")
                    // return as Long
            .getAs(Long.class)
                    // get answer
            .toBlocking().single();
    System.out.println(count);

    Observable<Boolean> begin = db.beginTransaction();
    Observable<Integer> updateCount = db
            // set everyones score to 99
            .update("insert into note(text) values(?)")
                    // is within transaction
            .dependsOn(begin)
                    // new score
            .parameter("hello")
                    // execute
            .count();
    Observable<Boolean> commit = db.commit(updateCount);
    count = db
            .select("select count(*) from note")
                    // depends on
            .dependsOn(commit)
                    // return as Long
            .getAs(Long.class)
                    // log
            .doOnEach(RxUtil.log())
                    // get answer
            .toBlocking().single();
    System.out.println(count);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:35，代码来源:TransactionEaxmple.java

示例8: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "123456");
    List<String> names = db.select("select alarm_user_id, alarm_user_name from alarm_user")
            .get(rs -> rs.getString(1) + "-" + rs.getString(2)).toList().toBlocking().single();
    System.out.println(names);

}

开发者ID:edgar615，项目名称:javase-study，代码行数:8，代码来源:GetExample.java

示例9: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");
    Observable<Integer> keys =
            db.update("insert into note(text) values(?)")
                    .parameter("hello", "there")
                    .returnGeneratedKeys()
                    .getAs(Integer.class);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:9，代码来源:KeyExample.java

示例10: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
        Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

        Observable<Integer> score = Observable
                // parameters for coming update
                .just(4, "FRED")
                        // update Fred's score to 4
                .lift(db.update("update person set score=? where name=?")
                        //parameters are pushed
                        .parameterOperator())
                        // update everyone with score of 4 to 14
                .lift(db.update("update person set score=? where score=?")
                        .parameters(14, 4)
                                //wait for completion of previous observable
                        .dependsOnOperator())
                        // get Fred's score
                .lift(db.select("select score from person where name=?")
                        .parameters("FRED")
                                //wait for completion of previous observable
                        .dependsOnOperator()
                        .getAs(Integer.class));

        //If the query does not require parameters you can push it an empty list and use the parameterListOperator() to force execution.
//        Observable<Integer> rowsAffected = Observable
//                //generate two integers
//                .range(1,2)
//                        //replace the integers with empty observables
//                .map(toEmpty())
//                        //execute the update twice with an empty list
//                .lift(db.update("update person set score = score + 1")
//                        .parameterListOperator())
//                        // flatten
//                .lift(RxUtil.<Integer> flatten())
//                        // total the affected records
//                .lift(SUM_INTEGER);
    }

开发者ID:edgar615，项目名称:javase-study，代码行数:37，代码来源:LiftExample.java

示例11: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

    //Insert a Clob
    String document = null;
    Observable<Integer> count = db
            .update("insert into person_clob(name,document) values(?,?)")
            .parameter("FRED")
            .parameter(Database.toSentinelIfNull(document)).count();

    //or
    Reader reader = null;
     count = db
            .update("insert into person_clob(name,document) values(?,?)")
            .parameter("FRED")
            .parameter(reader).count();

    //Insert a Null Clob
    count = db
            .update("insert into person_clob(name,document) values(?,?)")
            .parameter("FRED")
            .parameterClob(null).count();
    //or
    count = db
            .update("insert into person_clob(name,document) values(?,?)")
            .parameter("FRED")
            .parameter(Database.NULL_CLOB).count();

    //Read a Clob
    Observable<String> document2 = db.select("select document from person_clob")
            .getAs(String.class);

    //or
    Observable<Reader> document3 = db.select("select document from person_clob")
            .getAs(Reader.class);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:37，代码来源:ClobExample.java

示例12: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");
    List<AlarmUser> names = db.select("select alarm_user_id, alarm_user_name from alarm_user")
           .autoMap(AlarmUser.class).toList().toBlocking().single();
    System.out.println(names);

    List<AlarmUser2> alarmUser2 = db.select("select alarm_user_id, alarm_user_name from alarm_user")
            .autoMap(AlarmUser2.class).toList().toBlocking().single();
    System.out.println(alarmUser2);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:11，代码来源:AutoMapExample.java

示例13: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");

    //Insert a Blob
    byte[] bytes = new byte[0];
    Observable<Integer> count = db
            .update("insert into person_blob(name,document) values(?,?)")
            .parameter("FRED")
            .parameter(Database.toSentinelIfNull(bytes)).count();


    //Insert a Null Blob
    count = db
            .update("insert into person_blob(name,document) values(?,?)")
            .parameter("FRED")
            .parameterBlob(null).count();
    //or
    count = db
            .update("insert into person_clob(name,document) values(?,?)")
            .parameter("FRED")
            .parameter(Database.NULL_BLOB).count();

    //Read a Blob
    Observable<byte[]> document = db.select("select document from person_clob")
            .getAs(byte[].class);

    //or
    Observable<InputStream> document2 = db.select("select document from person_clob")
            .getAs(InputStream.class);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:31，代码来源:BlobExample.java

示例14: test

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
@Test
public void test() {
    TestSubscriber<Object> ts = new TestSubscriber<Object>();
    Database db = DatabaseCreator.db();
    db.select("select name from Person").autoMap(Thing.class).count().subscribe(ts);
    ts.assertError(SQLRuntimeException.class);
    assertTrue(ts.getOnErrorEvents().get(0).getMessage()
            .startsWith("query column names do not include 'bingo'"));
}

开发者ID:davidmoten，项目名称:rxjava-jdbc，代码行数:10，代码来源:ColumnNotFoundTest.java

示例15: configure

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
@Override
public void configure(final Env env, final Config config, final Binder binder) {
  Key<DataSource> dskey = Key.get(DataSource.class, Names.named(name));
  DataSource ds = env.get(dskey)
      .orElseThrow(() -> new NoSuchElementException("DataSource missing: " + dskey));
  Database db = Database.fromDataSource(ds);

  env.serviceKey().generate(Database.class, name, k -> binder.bind(k).toInstance(db));

  // close on shutdown
  env.onStop(db::close);
}

开发者ID:jooby-project，项目名称:jooby，代码行数:13，代码来源:RxJdbc.java

示例16: onStop

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
@Test
public void onStop() throws Exception {
  new MockUnit(Env.class, Config.class, Binder.class)
      .expect(bind)
      .expect(onStop)
      .expect(unit -> {
        expect(unit.get(Database.class).close()).andReturn(null);
      })
      .run(unit -> {
        new RxJdbc()
            .configure(unit.get(Env.class), config(), unit.get(Binder.class));
      }, unit -> {
        unit.captured(Throwing.Runnable.class).iterator().next().run();
      });
}

开发者ID:jooby-project，项目名称:jooby，代码行数:16，代码来源:RxJdbcTest.java

示例17: db

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
@Bean
public Database db(DataSource ds){
    return Database.fromDataSource(ds);
}

开发者ID:hantsy，项目名称:spring-reactive-sample，代码行数:5，代码来源:DataSourceConfig.java

示例18: RxJavaPostRepository

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
RxJavaPostRepository(Database db) {
    this.db = db;
}

开发者ID:hantsy，项目名称:spring-reactive-sample，代码行数:4，代码来源:RxJavaPostRepository.java

示例19: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");
    TupleN<String> names = db.select("select alarm_user_id, alarm_user_name, org_code from alarm_user")
           .getTupleN(String.class).last().toBlocking().single();
    System.out.println(names);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:7，代码来源:TupleNExample.java

示例20: main

import com.github.davidmoten.rx.jdbc.Database; //导入依赖的package包/类
public static void main(String[] args) {
    Database db = Database.from("jdbc:mysql://127.0.0.1:3306/alarm_user", "root", "");
    Tuple2<String, String> names = db.select("select alarm_user_id, alarm_user_name from alarm_user")
           .getAs(String.class, String.class).last().toBlocking().single();
    System.out.println(names);
}

开发者ID:edgar615，项目名称:javase-study，代码行数:7，代码来源:Tuple2Example.java

注：本文中的com.github.davidmoten.rx.jdbc.Database类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ProcessCommunicator类代码示例发布时间：2022-05-22

Java Platform类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18271|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9677|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8179|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8549|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8457|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9392|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8430|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8414|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Database类代码示例

示例1: main

示例2: main

示例3: main

示例4: main

示例5: ExtractorClient

示例6: main

示例7: main

示例8: main

示例9: main

示例10: main

示例11: main

示例12: main

示例13: main

示例14: test

示例15: configure

示例16: onStop

示例17: db

示例18: RxJavaPostRepository

示例19: main

示例20: main

请发表评论

全部评论

上一篇：

下一篇：

creativetimofficial/material-dashboard-r

CVE-2022-30517

pngwn/MDsveX: A markdown preprocessor fo

kubernetes/examples: Kubernetes applicat

中国4a广告公司100强图谱

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053