Java Yank类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: insertTest

import org.knowm.yank.Yank; //导入依赖的package包/类
public static long insertTest(Test test) {
    if (test.getStatus() == null) {
        LOGGER.warn("Test {} for build {} has no status.  Setting the status to error.", test.getName(), test.getBuildId());
        test.setStatus("error");
    }

    Object[] params = new Object[]{
            test.getBuildId(),
            test.getTaskId(),
            test.getTestId(),
            test.getName(),
            test.getClassName(),
            test.getStatus(),
            test.durationInMillis()
    };

    long newId = Yank.insertSQLKey("INSERT_TEST", params);
    LOGGER.debug("Inserted test {} for build {}", test.getName(), test.getBuildId());
    return newId;
}

开发者ID:gradle，项目名称:ge-export，代码行数:21，代码来源:TestsDAO.java

示例2: doCreateItemsTableIfNot

import org.knowm.yank.Yank; //导入依赖的package包/类
@Override
public ItemsVO doCreateItemsTableIfNot(ItemsVO vo) {
    // boolean tableExists = Yank.queryScalar(SQL_IF_TABLE_EXISTS.replace("#searchTable#",
    // vo.getItemsManageTable().toUpperCase()), String.class, null) == null;
    boolean tableExists = doIfTableExists(vo);
    if (!tableExists) {
        String sql = StringUtilsExt.replaceArrayMerge(SQL_CREATE_ITEMS_TABLE_IF_NOT,
                new String[] { "#itemsManageTable#", "#colname#", "#coltype#" },
                new String[] { vo.getItemsManageTable().toUpperCase(), vo.getColname(), vo.getColtype() });
        logger.debug("JDBC::doCreateItemsTableIfNot tableExists={} therefore sql={}", tableExists, sql);
        Yank.execute(sql, null);
    } else {
        logger.debug("JDBC::doCreateItemsTableIfNot tableExists={}, did not CREATE TABLE", tableExists);
    }
    return vo;
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:17，代码来源:JdbcDerbyDAO.java

示例3: getGuild

import org.knowm.yank.Yank; //导入依赖的package包/类
public DbGuild getGuild(IGuild guild){
    if(Karren.conf.getAllowSQLRW()){
        if(!dbGuildCache.containsKey(guild.getStringID())) {
            String sql = "INSERT IGNORE Guild (GuildID, GuildOwner, GuildName, CommandPrefix, RollDifficulty, MaxVolume, RandomRange, OverrideChannel) VALUES (?, ?, ?, null, -1, 40, 0, 0)";
            Object[] params = {guild.getStringID(), guild.getOwner().getName(), guild.getName()};
            Yank.execute(sql, params);
            sql = "SELECT * FROM Guild WHERE GuildID=?";
            Object[] params2 = {guild.getStringID()};
            DbGuild dbGuild = Yank.queryBean(sql, DbGuild.class, params2);
            dbGuildCache.put(guild.getStringID(), dbGuild);
            return dbGuild;
        } else {
            return dbGuildCache.get(guild.getStringID());
        }
    }
    return null;
}

开发者ID:ripxfrostbite，项目名称:karren-sama，代码行数:18，代码来源:MySQLInterface.java

示例4: getWordCount

import org.knowm.yank.Yank; //导入依赖的package包/类
public DbWordcount getWordCount(String word){
    if(Karren.conf.getAllowSQLRW()) {
        if(!dbWordcountCache.containsKey(word)) {
            String sql = "INSERT IGNORE WordCounts (WordID, Word, Count, CountStarted) VALUES (null, ?, 1, null)";
            Object[] params = {word};
            Yank.execute(sql, params);
            sql = "SELECT * FROM WordCounts WHERE Word=?";
            DbWordcount dbWordcount = Yank.queryBean(sql, DbWordcount.class, params);
            dbWordcountCache.put(word, dbWordcount);
            return dbWordcount;
        } else {
            return dbWordcountCache.get(word);
        }
    }
    return null;
}

开发者ID:ripxfrostbite，项目名称:karren-sama，代码行数:17，代码来源:MySQLInterface.java

示例5: getUserData

import org.knowm.yank.Yank; //导入依赖的package包/类
public DbUser getUserData(IUser user){
    if(Karren.conf.getAllowSQLRW()) {
        if(!dbUserCache.containsKey(user.getStringID())) {
            String sql = "INSERT IGNORE User (UserID, TimeLeft) VALUES (?, null)";
            Object[] params = {user.getLongID()};
            Yank.execute(sql, params);
            sql = "SELECT * FROM User WHERE UserID=?";
            Object[] params2 = {user.getLongID()};
            DbUser dbUser = Yank.queryBean(sql, DbUser.class, params2);
            dbUserCache.put(user.getStringID(), dbUser);
            return dbUser;
        } else {
            return dbUserCache.get(user.getStringID());
        }
    }
    return null;
}

开发者ID:ripxfrostbite，项目名称:karren-sama，代码行数:18，代码来源:MySQLInterface.java

示例6: cleanupBot

import org.knowm.yank.Yank; //导入依赖的package包/类
public void cleanupBot(){
    Karren.bot.isKill = true;
    //Unhook and shutdown interaction system
    Karren.bot.client.getDispatcher().unregisterListener(Karren.bot.interactionListener);
    Karren.bot.ic.loadDefaultInteractions();
    Yank.releaseAllConnectionPools();
    //Interactions reset to default state and unregistered
    if(Karren.bot.ar.isAlive())
        Karren.bot.ar.setKill(true);
    if(Karren.bot.cm.isAlive())
        Karren.bot.cm.kill();
    if(Karren.bot.client.isReady()) {
        try {
            Karren.bot.client.logout();
        } catch (DiscordException e) {
            e.printStackTrace();
        }
    }

    Karren.bot = null;
    System.gc();
}

开发者ID:ripxfrostbite，项目名称:karren-sama，代码行数:23，代码来源:Watchdog.java

示例7: handle

import org.knowm.yank.Yank; //导入依赖的package包/类
@Override
public void handle(ReadyEvent event){
    //Initialize database connection pool
    Karren.log.info("Initializing Yank database pool");
    Properties dbSettings = new Properties();
    dbSettings.setProperty("jdbcUrl", "jdbc:mysql://" + conf.getSqlhost() + ":" + conf.getSqlport() + "/" + conf.getSqldb() + "?useUnicode=true&characterEncoding=UTF-8");
    dbSettings.setProperty("username", conf.getSqluser());
    dbSettings.setProperty("password", conf.getSqlpass());

    Yank.setupDefaultConnectionPool(dbSettings);

    //Start auto reminder
    Karren.bot.getAr().start();

    //Start ChannelMonitor
    Karren.bot.getCm().start();

    if(!Karren.conf.isTestMode())
        event.getClient().changePresence(StatusType.ONLINE, ActivityType.PLAYING, "KarrenSama Ver." + Karren.botVersion);
    else
        event.getClient().changePresence(StatusType.ONLINE, ActivityType.PLAYING, "TEST MODE");
}

开发者ID:ripxfrostbite，项目名称:karren-sama，代码行数:23，代码来源:ConnectCommand.java

示例8: getDatabaseProductName

import org.knowm.yank.Yank; //导入依赖的package包/类
private static String getDatabaseProductName() {
    if (databaseProductName.get() == null) {
        synchronized (databaseProductName) {
            if (databaseProductName.get() == null) {
                try (Connection connection = Yank.getDefaultConnectionPool().getConnection()) {
                    databaseProductName.set(connection.getMetaData().getDatabaseProductName());
                    LOGGER.info("Connected to a {} database.", databaseProductName.get());
                } catch (SQLException e) {
                    throw new RuntimeException(e);
                }
            }
        }
    }
    return databaseProductName.get();
}

开发者ID:gradle，项目名称:ge-export，代码行数:16，代码来源:SqlHelper.java

示例9: loadSqlQueries

import org.knowm.yank.Yank; //导入依赖的package包/类
/**
 * Loads all of the SQL queries stored in a properties file specified by GE_EXPORT_SCHEMA_PROPERTY_KEY, or 'postgres-sql.properties'
 */
public static void loadSqlQueries() {
    if (!sqlQueriesLoaded.get()) {
        synchronized (sqlQueriesLoaded) {
            if (!sqlQueriesLoaded.getAndSet(true)) {
                String propertiesFile = isMySql() ? "mysql-sql.properties" : "postgres-sql.properties";
                LOGGER.info("Loading SQL queries from {}", propertiesFile);
                Properties createTableProps = PropertiesUtils.getPropertiesFromClasspath(propertiesFile);
                Yank.addSQLStatements(createTableProps);
            }
        }
    }
}

开发者ID:gradle，项目名称:ge-export，代码行数:16，代码来源:SqlHelper.java

示例10: insertCustomValue

import org.knowm.yank.Yank; //导入依赖的package包/类
public static long insertCustomValue(CustomValue cv) {
    Object[] params = new Object[]{
            cv.getBuildId(),
            cv.getKey(),
            cv.getValue(),
    };

    long newId = Yank.insertSQLKey("INSERT_CUSTOM_VALUE", params);
    LOGGER.debug("Inserted custom value with key {} for build {}", cv.getKey(), cv.getBuildId());
    return newId;
}

开发者ID:gradle，项目名称:ge-export，代码行数:12，代码来源:CustomValueDAO.java

示例11: insertBuild

import org.knowm.yank.Yank; //导入依赖的package包/类
public static long insertBuild(Build build) {
    LOGGER.debug("Inserting build {} into the database.", build.getBuildId());

    Object start;
    Object finish;
    if (SqlHelper.isMySql()) {
        start = LocalDateTime.ofInstant(build.getTimer().getStartTime(), ZoneOffset.UTC);
        finish = LocalDateTime.ofInstant(build.getTimer().getFinishTime(), ZoneOffset.UTC);
    } else {
        start = OffsetDateTime.ofInstant(build.getTimer().getStartTime(), ZoneId.of(build.getTimer().getTimeZoneId()));
        finish = OffsetDateTime.ofInstant(build.getTimer().getFinishTime(), ZoneId.of(build.getTimer().getTimeZoneId()));
    }

    Object[] params = new Object[]{
            build.getBuildId(),
            build.getUserName(),
            build.getRootProjectName(),
            start,
            finish,
            build.getStatus(),
            build.getTagsAsSingleString()
    };

    Long generatedId = Yank.insertSQLKey("INSERT_BUILD", params);
    if (generatedId == 0) {
        throw new RuntimeException("Unable to save build record for " + build.getBuildId());
    }
    return generatedId;
}

开发者ID:gradle，项目名称:ge-export，代码行数:30，代码来源:BuildDAO.java

示例12: run

import org.knowm.yank.Yank; //导入依赖的package包/类
public static void run() {
    LOGGER.info("Creating Database");
    SqlHelper.loadSqlQueries();

    Yank.executeSQLKey("DROP_CUSTOM_VALUES", null);
    Yank.executeSQLKey("DROP_TESTS", null);
    Yank.executeSQLKey("DROP_TASKS", null);
    Yank.executeSQLKey("DROP_BUILDS", null);

    Yank.executeSQLKey("CREATE_BUILDS", null);
    Yank.executeSQLKey("CREATE_TASKS", null);
    Yank.executeSQLKey("CREATE_TESTS", null);
    Yank.executeSQLKey("CREATE_CUSTOM_VALUES", null);
}

开发者ID:gradle，项目名称:ge-export，代码行数:15，代码来源:CreateDB.java

示例13: setup

import org.knowm.yank.Yank; //导入依赖的package包/类
@Before
public void setup() {
    String propertiesFile = System.getProperty(GE_EXPORT_TEST_DATABASE_PROPERTIES_KEY, "test-db-info.properties");
    Properties dbProps = PropertiesUtils.getPropertiesFromClasspath(propertiesFile);
    Yank.setThrowWrappedExceptions(true);
    Yank.setupDefaultConnectionPool(dbProps);
}

开发者ID:gradle，项目名称:ge-export，代码行数:8，代码来源:DatabaseBaseIntegrationTest.java

示例14: openConnection

import org.knowm.yank.Yank; //导入依赖的package包/类
/***********************
 * DATABASE CONNECTION *
 ***********************/
protected boolean openConnection() {
    logger.debug("JDBC::openConnection isDriverAvailable: {}", conf.isDriverAvailable());
    if (conf.isDriverAvailable() && !conf.isDbConnected()) {
        logger.info("JDBC::openConnection: Driver is available::Yank setupDataSource");
        Yank.setupDefaultConnectionPool(conf.getHikariConfiguration());
        conf.setDbConnected(true);
        return true;
    } else if (!conf.isDriverAvailable()) {
        logger.warn("JDBC::openConnection: no driver available!");
        initialized = false;
        return false;
    }
    return true;
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:18，代码来源:JdbcMapper.java

示例15: doStoreItemValue

import org.knowm.yank.Yank; //导入依赖的package包/类
/*************
 * ITEM DAOs *
 *************/
@Override
public void doStoreItemValue(Item item, ItemVO vo) {
    vo = storeItemValueProvider(item, vo);
    String sql = StringUtilsExt.replaceArrayMerge(SQL_INSERT_ITEM_VALUE,
            new String[] { "#tableName#", "#dbType#", "#tablePrimaryValue#" },
            new String[] { vo.getTableName(), vo.getDbType(), sqlTypes.get("tablePrimaryValue") });
    Object[] params = new Object[] { vo.getValue() };
    logger.debug("JDBC::doStoreItemValue sql={} value='{}'", sql, vo.getValue());
    Yank.execute(sql, params);
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:14，代码来源:JdbcH2DAO.java

示例16: doCreateNewEntryInItemsTable

import org.knowm.yank.Yank; //导入依赖的package包/类
public Long doCreateNewEntryInItemsTable(ItemsVO vo) {
    String sql = StringUtilsExt.replaceArrayMerge(SQL_CREATE_NEW_ENTRY_IN_ITEMS_TABLE,
            new String[] { "#itemsManageTable#", "#itemname#" },
            new String[] { vo.getItemsManageTable(), vo.getItemname() });
    logger.debug("JDBC::doCreateNewEntryInItemsTable sql={}", sql);
    return Yank.insert(sql, null);
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:8，代码来源:JdbcBaseDAO.java

示例17: doCreateItemsTableIfNot

import org.knowm.yank.Yank; //导入依赖的package包/类
public ItemsVO doCreateItemsTableIfNot(ItemsVO vo) {
    String sql = StringUtilsExt.replaceArrayMerge(SQL_CREATE_ITEMS_TABLE_IF_NOT,
            new String[] { "#itemsManageTable#", "#colname#", "#coltype#" },
            new String[] { vo.getItemsManageTable(), vo.getColname(), vo.getColtype() });
    logger.debug("JDBC::doCreateItemsTableIfNot sql={}", sql);
    Yank.execute(sql, null);
    return vo;
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:9，代码来源:JdbcBaseDAO.java

示例18: doGetItemTables

import org.knowm.yank.Yank; //导入依赖的package包/类
public List<ItemsVO> doGetItemTables(ItemsVO vo) {
    String sql = StringUtilsExt.replaceArrayMerge(SQL_GET_ITEM_TABLES,
            new String[] { "#jdbcUriDatabaseName#", "#itemsManageTable#" },
            new String[] { vo.getJdbcUriDatabaseName(), vo.getItemsManageTable() });
    logger.debug("JDBC::doGetItemTables sql={}", sql);
    return Yank.queryBeanList(sql, ItemsVO.class, null);
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:8，代码来源:JdbcBaseDAO.java

示例19: doStoreItemValue

import org.knowm.yank.Yank; //导入依赖的package包/类
public void doStoreItemValue(Item item, ItemVO vo) {
    vo = storeItemValueProvider(item, vo);
    String sql = StringUtilsExt.replaceArrayMerge(SQL_INSERT_ITEM_VALUE,
            new String[] { "#tableName#", "#tablePrimaryValue#" },
            new String[] { vo.getTableName(), sqlTypes.get("tablePrimaryValue") });
    Object[] params = new Object[] { vo.getValue(), vo.getValue() };
    logger.debug("JDBC::doStoreItemValue sql={} value='{}'", sql, vo.getValue());
    Yank.execute(sql, params);
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:10，代码来源:JdbcBaseDAO.java

示例20: doGetHistItemFilterQuery

import org.knowm.yank.Yank; //导入依赖的package包/类
public List<HistoricItem> doGetHistItemFilterQuery(Item item, FilterCriteria filter, int numberDecimalcount,
        String table, String name) {
    String sql = histItemFilterQueryProvider(filter, numberDecimalcount, table, name);
    logger.debug("JDBC::doGetHistItemFilterQuery sql={}", sql);
    List<Object[]> m = Yank.queryObjectArrays(sql, null);

    List<HistoricItem> items = new ArrayList<HistoricItem>();
    for (int i = 0; i < m.size(); i++) {
        items.add(new JdbcItem(item.getName(), getState(item, m.get(i)[1]), objectAsDate(m.get(i)[0])));
    }
    return items;
}

开发者ID:openhab，项目名称:openhab1-addons，代码行数:13，代码来源:JdbcBaseDAO.java

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