diff --git a/presto-main/src/main/java/com/facebook/presto/connector/informationSchema/InformationSchemaPageSourceProvider.java b/presto-main/src/main/java/com/facebook/presto/connector/informationSchema/InformationSchemaPageSourceProvider.java index 19ce81e432c05..a23791e777755 100644 --- a/presto-main/src/main/java/com/facebook/presto/connector/informationSchema/InformationSchemaPageSourceProvider.java +++ b/presto-main/src/main/java/com/facebook/presto/connector/informationSchema/InformationSchemaPageSourceProvider.java @@ -164,7 +164,7 @@ private InternalTable buildColumns(Session session, Set pr column.getName(), ordinalPosition, null, - "YES", + column.isNullable() ? "YES" : "NO", column.getType().getDisplayName(), column.getComment(), column.getExtraInfo()); diff --git a/presto-mysql/src/test/java/com/facebook/presto/plugin/mysql/TestMySqlIntegrationSmokeTest.java b/presto-mysql/src/test/java/com/facebook/presto/plugin/mysql/TestMySqlIntegrationSmokeTest.java index 4c01f529c437e..011d3b9a39bae 100644 --- a/presto-mysql/src/test/java/com/facebook/presto/plugin/mysql/TestMySqlIntegrationSmokeTest.java +++ b/presto-mysql/src/test/java/com/facebook/presto/plugin/mysql/TestMySqlIntegrationSmokeTest.java @@ -299,4 +299,11 @@ private void execute(String sql) statement.execute(sql); } } + + @Test + public void testSelectInformationSchemaColumnIsNullable() + { + assertUpdate("CREATE TABLE test_column (name VARCHAR NOT NULL, email VARCHAR)"); + assertQuery("SELECT is_nullable FROM information_schema.columns WHERE table_name = 'test_column'", "VALUES 'NO','YES'"); + } }